Keep text / byte stream handlers between room disconnects (#1741)

Author: 1egoman

.changeset/good-rockets-hug.md

@@ -0,0 +1,5 @@
+---
+'livekit-client': patch
+---
+
+Keep text / byte stream handlers between room disconnects

src/room/Room.ts

@@ -1550,7 +1550,7 @@ class Room extends (EventEmitter as new () => TypedEmitter<RoomEventCallbacks>)
     this.isResuming = false;
     this.bufferedEvents = [];
     this.transcriptionReceivedTimes.clear();
-    this.incomingDataStreamManager.clearHandlersAndControllers();
+    this.incomingDataStreamManager.clearControllers();
     if (this.state === ConnectionState.Disconnected) {
       return;
     }

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

@@ -55,11 +55,9 @@ export default class IncomingDataStreamManager {
     this.byteStreamHandlers.delete(topic);
   }
 
-  clearHandlersAndControllers() {
+  clearControllers() {
     this.byteStreamControllers.clear();
     this.textStreamControllers.clear();
-    this.byteStreamHandlers.clear();
-    this.textStreamHandlers.clear();
   }
 
   validateParticipantHasNoActiveDataStreams(participantIdentity: string) {

src/room/token-source/TokenSource.ts

@@ -11,7 +11,7 @@ import {
   TokenSourceFixed,
   type TokenSourceResponseObject,
 } from './types';
-import { decodeTokenPayload, isResponseTokenValid } from './utils';
+import { areTokenSourceFetchOptionsEqual, decodeTokenPayload, isResponseTokenValid } from './utils';
 
 /** A TokenSourceCached is a TokenSource which caches the last {@link TokenSourceResponseObject} value and returns it
  * until a) it expires or b) the {@link TokenSourceFetchOptions} provided to .fetch(...) change. */
@@ -250,6 +250,7 @@ export {
   type TokenSourceEndpoint,
   type TokenSourceSandboxTokenServer,
   decodeTokenPayload,
+  areTokenSourceFetchOptionsEqual,
 };
 
 export const TokenSource = {