Merge pull request #187 from xmtp/kele/unsubscribe-from-stream

fix: unsubscribe message event
xmtp · Dec 18, 2023 · e95063a · e95063a
2 parents e6053cd + f22e116
commit e95063a
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/lib/Conversation.ts b/src/lib/Conversation.ts
@@ -229,7 +229,7 @@ export class Conversation<ContentTypes> {
   ): () => void {
     XMTP.subscribeToMessages(this.client.address, this.topic)
     const hasSeen = {}
-    XMTP.emitter.addListener(
+    const messageSubscription = XMTP.emitter.addListener(
       'message',
       async ({
         clientAddress,
@@ -253,6 +253,7 @@ export class Conversation<ContentTypes> {
     )
 
     return () => {
+      messageSubscription.remove()
       XMTP.unsubscribeFromMessages(this.client.address, this.topic)
     }
   }