Fix bug in subscribeBroadcastEvent method

yorkie-team · Aug 21, 2024 · b692441 · b692441
1 parent 323f981
commit b692441
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/packages/sdk/src/document/document.ts b/packages/sdk/src/document/document.ts
@@ -1061,7 +1061,7 @@ export class Document<T, P extends Indexable = Indexable> {
   ): Unsubscribe {
     this.broadcastEventHandlers.set(topic, handler);
 
-    this.eventStream.subscribe((event) => {
+    const unsubscribe = this.eventStream.subscribe((event) => {
       for (const docEvent of event) {
         if (docEvent.type !== DocEventType.Broadcast) {
           continue;
@@ -1074,6 +1074,7 @@ export class Document<T, P extends Indexable = Indexable> {
     }, error);
 
     return () => {
+      unsubscribe();
       this.broadcastEventHandlers.delete(topic);
     };
   }