use normal promises

livekit · Sep 19, 2024 · b66e488 · b66e488
1 parent 66ec836
commit b66e488
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 5 deletions.
diff --git a/examples/publish-wav/index.ts b/examples/publish-wav/index.ts
@@ -60,10 +60,9 @@ while (written < dataSize) {
     Math.trunc(frameSize / channels),
   );
   await source.captureFrame(frame);
-  await source.waitForPlayout();
-
   written += frameSize;
 }
+await source.waitForPlayout();
 
 await room.disconnect();
 await dispose();
diff --git a/packages/livekit-rtc/src/audio_source.ts b/packages/livekit-rtc/src/audio_source.ts
@@ -29,7 +29,7 @@ export class AudioSource {
   currentQueueSize: number;
   /** @internal */
   release = () => {};
-  waitForPlayout = this.newPromise();
+  promise = this.newPromise();
   /** @internal */
   timeout?: ReturnType<typeof setTimeout> = undefined;
 
@@ -89,10 +89,14 @@ export class AudioSource {
   async newPromise() {
     return new Promise<void>((resolve) => {
       this.release = resolve;
-    }).then(() => {
+    });
+  }
+
+  async waitForPlayout() {
+    return this.promise.then(() => {
       this.lastCapture = 0;
       this.currentQueueSize = 0;
-      this.waitForPlayout = this.newPromise();
+      this.promise = this.newPromise();
     });
   }