Avoid uncaught errors related to send/disconnect races (#1674)

Co-authored-by: lukasIO <[email protected]>

Author: bryfox

.changeset/giant-ligers-flow.md

@@ -0,0 +1,5 @@
+---
+"livekit-client": patch
+---
+
+Avoid uncaught errors related to send/disconnect races

src/room/RTCEngine.ts

@@ -267,7 +267,9 @@ export default class RTCEngine extends (EventEmitter as new () => TypedEventEmit
 
       // create offer
       if (!this.subscriberPrimary || joinResponse.fastPublish) {
-        this.negotiate();
+        this.negotiate().catch((err) => {
+          log.error(err, this.logContext);
+        });
       }
 
       this.registerOnLineListener();
@@ -1338,7 +1340,9 @@ export default class RTCEngine extends (EventEmitter as new () => TypedEventEmit
     }
     if (needNegotiation) {
       // start negotiation
-      this.negotiate();
+      this.negotiate().catch((err) => {
+        log.error(err, this.logContext);
+      });
     }
 
     const targetChannel = this.dataChannelForKind(kind, subscriber);

src/room/data-stream/incoming/IncomingDataStreamManager.ts

@@ -124,6 +124,9 @@ export default class IncomingDataStreamManager {
 
       let streamController: ReadableStreamDefaultController<DataStream_Chunk>;
       const outOfBandFailureRejectingFuture = new Future<never>();
+      outOfBandFailureRejectingFuture.promise.catch((err) => {
+        this.log.error(err);
+      });
 
       const info: ByteStreamInfo = {
         id: streamHeader.streamId,
@@ -178,6 +181,10 @@ export default class IncomingDataStreamManager {
 
       let streamController: ReadableStreamDefaultController<DataStream_Chunk>;
       const outOfBandFailureRejectingFuture = new Future<never>();
+      outOfBandFailureRejectingFuture.promise.catch((err) => {
+        this.log.error(err);
+      });
+
       const info: TextStreamInfo = {
         id: streamHeader.streamId,
         mimeType: streamHeader.mimeType,