fix merge

leibale · leibale · commit 8ec485514ec2 · 2022-04-20T22:43:06.000-04:00
diff --git a/packages/client/lib/client/commands-queue.ts b/packages/client/lib/client/commands-queue.ts
@@ -356,7 +356,7 @@ export default class RedisCommandsQueue {
     }
 
     #handlePubSubReply(reply: any): boolean {
-        if (!this.#pubSubState || !Array.isArray(reply)) return false;
+        if (!this.#pubSubState.isActive || !Array.isArray(reply)) return false;
 
         if (RedisCommandsQueue.#PUB_SUB_MESSAGES.message.equals(reply[0])) {
             RedisCommandsQueue.#emitPubSubMessage(

Original file line number	Diff line number	Diff line change
`@@ -356,7 +356,7 @@ export default class RedisCommandsQueue {`
`356`	`356`	`}`
`357`	`357`
`358`	`358`	`#handlePubSubReply(reply: any): boolean {`
`359`		`- if (!this.#pubSubState \|\| !Array.isArray(reply)) return false;`
	`359`	`+ if (!this.#pubSubState.isActive \|\| !Array.isArray(reply)) return false;`
`360`	`360`
`361`	`361`	`if (RedisCommandsQueue.#PUB_SUB_MESSAGES.message.equals(reply[0])) {`
`362`	`362`	`RedisCommandsQueue.#emitPubSubMessage(`