redis/node-redis
1
0
Fork 0
mirror of https://github.com/redis/node-redis.git synced 2025-08-04 15:02:09 +03:00
Code Activity

clean code

Browse Source
This commit is contained in:
leibale
2022-01-03 16:37:03 -05:00
parent 7e2059b1cf
commit 24f3e3f43c
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
packages/client/lib/client/index.ts
View File

@@ -268,10 +268,10 @@ export default class RedisClient<M extends RedisModules, S extends RedisScripts>
.on('data', data => this.#queue.parseResponse(data)) .on('data', data => this.#queue.parseResponse(data))
.on('error', err => { .on('error', err => {
this.emit('error', err); this.emit('error', err);
if (!this.#socket.isOpen) { if (this.#socket.isOpen) {
this.#queue.flushAll(err);
} else {
this.#queue.flushWaitingForReply(err); this.#queue.flushWaitingForReply(err);
} else {
this.#queue.flushAll(err);
} }
}) })
.on('connect', () => this.emit('connect')) .on('connect', () => this.emit('connect'))