We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 0ba38ce commit 44ebc51Copy full SHA for 44ebc51
apps/sim/lib/mcp/pubsub.ts
@@ -131,12 +131,15 @@ class RedisMcpPubSub implements McpPubSubAdapter {
131
this.toolsChangedHandlers.clear()
132
this.workflowToolsChangedHandlers.clear()
133
134
+ const noop = () => {}
135
this.pub.removeAllListeners()
136
this.sub.removeAllListeners()
137
+ this.pub.on('error', noop)
138
+ this.sub.on('error', noop)
139
- this.sub.unsubscribe().catch(() => {})
- this.pub.quit().catch(() => {})
- this.sub.quit().catch(() => {})
140
+ this.sub.unsubscribe().catch(noop)
141
+ this.pub.quit().catch(noop)
142
+ this.sub.quit().catch(noop)
143
logger.info('Redis MCP pub/sub disposed')
144
}
145
0 commit comments