Await pending publications with timeout (#1324)

* Await pending publications with timeout * Create tame-news-study.md
livekit · Nov 28, 2024 · cc14de4 · cc14de4
1 parent e511197
commit cc14de4
Show file tree

Hide file tree

Showing 2 changed files with 17 additions and 5 deletions.
diff --git a/.changeset/tame-news-study.md b/.changeset/tame-news-study.md
@@ -0,0 +1,5 @@
+---
+"livekit-client": patch
+---
+
+Await pending publications with timeout
diff --git a/src/room/participant/LocalParticipant.ts b/src/room/participant/LocalParticipant.ts
@@ -2016,11 +2016,18 @@ export default class LocalParticipant extends Participant {
   }
 
   private async waitForPendingPublicationOfSource(source: Track.Source) {
-    const publishPromiseEntry = Array.from(this.pendingPublishPromises.entries()).find(
-      ([pendingTrack]) => pendingTrack.source === source,
-    );
-    if (publishPromiseEntry) {
-      return publishPromiseEntry[1];
+    const waitForPendingTimeout = 10_000;
+    const startTime = Date.now();
+
+    while (Date.now() < startTime + waitForPendingTimeout) {
+      const publishPromiseEntry = Array.from(this.pendingPublishPromises.entries()).find(
+        ([pendingTrack]) => pendingTrack.source === source,
+      );
+      if (publishPromiseEntry) {
+        return publishPromiseEntry[1];
+      }
+      sleep(20);
     }
+    throw new Error('waiting for pending publication promise timed out');
   }
 }