redis/node-redis
1
0
Fork 0
mirror of https://github.com/redis/node-redis.git synced 2025-08-07 13:22:56 +03:00
Code Activity

fix #1734 - fix PubSub unsubscribe race condition

Browse Source
This commit is contained in:
Leibale Eidelman
2021-12-11 08:33:46 -05:00
committed by GitHub
parent 0b2a8d7c3c
commit bb75b06d67
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
packages/client/lib/client/commands-queue.ts
View File

@@ -73,7 +73,10 @@ export default class RedisCommandsQueue {
static #emitPubSubMessage(listenersMap: PubSubListenersMap, message: Buffer, channel: Buffer, pattern?: Buffer): void { static #emitPubSubMessage(listenersMap: PubSubListenersMap, message: Buffer, channel: Buffer, pattern?: Buffer): void {
const keyString = (pattern || channel).toString(), const keyString = (pattern || channel).toString(),
listeners = listenersMap.get(keyString)!; listeners = listenersMap.get(keyString);
if (!listeners) return;
for (const listener of listeners.buffers) { for (const listener of listeners.buffers) {
listener(message, channel); listener(message, channel);
} }