diff --git a/packages/backend/src/server/api/stream/Connection.ts b/packages/backend/src/server/api/stream/Connection.ts index 8d8f211af3..7c73014012 100644 --- a/packages/backend/src/server/api/stream/Connection.ts +++ b/packages/backend/src/server/api/stream/Connection.ts @@ -382,6 +382,7 @@ export default class Connection { for (const k of this.subscribingNotes.keys()) { this.subscriber.off(`noteStream:${k}`, this.onNoteStreamMessage); } + this.wsConnection.off('message', this.onWsConnectionMessage); this.fetchIntervalId = null; this.channels.clear();