refactor: improve saveToFileSystem to use PromiseQueue for better asy…

…nc handling
shinyoshiaki · Feb 12, 2025 · 55cb8da · 55cb8da
1 parent 65d55f6
commit 55cb8da
Showing 1 changed file with 28 additions and 21 deletions.
diff --git a/packages/rtp/src/extra/processor/webmCallback.ts b/packages/rtp/src/extra/processor/webmCallback.ts
@@ -51,30 +51,37 @@ export class WebmCallback extends WebmBase {
  * @param path
  * @returns eol
  */
-export const saveToFileSystem = (path: string) => async (value: WebmOutput) => {
-  if (value.saveToFile) {
-    await appendFile(path, value.saveToFile);
+export const saveToFileSystem = (path: string) => {
+  const queue = new PromiseQueue();
+  return async (value: WebmOutput): Promise<boolean> => {
+    return await queue.push<boolean>(async () => {
+      if (value.saveToFile) {
+        await appendFile(path, value.saveToFile);
 
-    return false;
-  } else if (value.eol) {
-    const { durationElement } = value.eol;
-    const handler = await open(path, "r+");
+        return false;
+      } else if (value.eol) {
+        const { durationElement } = value.eol;
+        const handler = await open(path, "r+");
 
-    // set duration
-    await handler.write(
-      durationElement,
-      0,
-      durationElement.length,
-      DurationPosition,
-    );
+        // set duration
+        await handler.write(
+          durationElement,
+          0,
+          durationElement.length,
+          DurationPosition,
+        );
 
-    // set size
-    const meta = await stat(path);
-    const resize = replaceSegmentSize(meta.size);
-    await handler.write(resize, 0, resize.length, SegmentSizePosition);
+        // set size
+        const meta = await stat(path);
+        const resize = replaceSegmentSize(meta.size);
+        await handler.write(resize, 0, resize.length, SegmentSizePosition);
 
-    await handler.close();
+        await handler.close();
 
-    return true;
-  }
+        return true;
+      }
+
+      return false;
+    });
+  };
 };