Skip to content

Commit ba04289

Browse files
committed
fix(core): don't unregister stream handler on disconnect
1 parent c734b92 commit ba04289

File tree

1 file changed

+1
-3
lines changed

1 file changed

+1
-3
lines changed

packages/core/src/components/textStream.ts

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -106,9 +106,7 @@ export function setupTextStream(room: Room, topic: string): Observable<TextStrea
106106
observableCache.set(cacheKey, sharedObservable);
107107

108108
// Add cleanup when room is disconnected
109-
room.once(RoomEvent.Disconnected, () => {
110-
room.unregisterTextStreamHandler(topic);
111-
textStreamsSubject.complete();
109+
room.on(RoomEvent.Disconnected, () => {
112110
getObservableCache().delete(cacheKey);
113111
});
114112

0 commit comments

Comments
 (0)