Method flushAll

packages/client/lib/client/commands-queue.ts:627–635

(err: Error)

  }

  flushAll(err: Error): void {
    this.resetDecoder();
    this.#pubSub.reset();
    this.#flushWaitingForReply(err);
    for (const node of this.#toWrite) {
      RedisCommandsQueue.#flushToWrite(node, err);
    }
    this.#toWrite.reset();
  }

  isEmpty() {
    return this.#toWrite.length === 0 && this.#waitingForReply.length === 0;