Close streamcontrollers when datatrack gets unpublished (#1879)

Author: lukasIO

.changeset/quiet-suits-matter.md

@@ -0,0 +1,5 @@
+---
+"livekit-client": patch
+---
+
+Close streamcontrollers when datatrack gets unpublished

src/room/data-track/incoming/IncomingDataTrackManager.ts

@@ -436,6 +436,9 @@ export default class IncomingDataTrackManager extends (EventEmitter as new () =>
     this.descriptors.delete(sid);
 
     if (descriptor.subscription.type === 'active') {
+      descriptor.subscription.streamControllers.forEach((controller) => {
+        controller.close();
+      });
       this.subscriptionHandles.delete(descriptor.subscription.subcriptionHandle);
     }
 
@@ -583,6 +586,10 @@ export default class IncomingDataTrackManager extends (EventEmitter as new () =>
       if (descriptor.subscription.type === 'pending') {
         descriptor.subscription.completionFuture.reject?.(DataTrackSubscribeError.disconnected());
       }
+
+      if (descriptor.subscription.type === 'active') {
+        descriptor.subscription.streamControllers.forEach((controller) => controller.close());
+      }
     }
     this.descriptors.clear();
   }