We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 57bd86e commit e307d1fCopy full SHA for e307d1f
packages/client/lib/client/commands-queue.ts
@@ -108,7 +108,8 @@ export default class RedisCommandsQueue {
108
109
#decoder = new RESP2Decoder({
110
returnStringsAsBuffers: () => {
111
- return !!this.#waitingForReply.head?.value.returnBuffers || !!this.#pubSubState;
+ return !!this.#waitingForReply.head?.value.returnBuffers ||
112
+ this.#pubSubState.isActive;
113
},
114
onReply: reply => {
115
if (this.#handlePubSubReply(reply)) {
0 commit comments