From 24f3e3f43c9f89238d21a8d63e16ca365545ad4c Mon Sep 17 00:00:00 2001
From: leibale <leibale1998@gmail.com>
Date: Mon, 3 Jan 2022 16:37:03 -0500
Subject: [PATCH] clean code

---
 packages/client/lib/client/index.ts | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/packages/client/lib/client/index.ts b/packages/client/lib/client/index.ts
index c9f04dc037..cae78e7f49 100644
--- a/packages/client/lib/client/index.ts
+++ b/packages/client/lib/client/index.ts
@@ -268,10 +268,10 @@ export default class RedisClient<M extends RedisModules, S extends RedisScripts>
             .on('data', data => this.#queue.parseResponse(data))
             .on('error', err => {
                 this.emit('error', err);
-                if (!this.#socket.isOpen) {
-                    this.#queue.flushAll(err);
-                } else {
+                if (this.#socket.isOpen) {
                     this.#queue.flushWaitingForReply(err);
+                } else {
+                    this.#queue.flushAll(err);
                 }
             })
             .on('connect', () => this.emit('connect'))