Method #returnClient

packages/client/lib/client/pool.ts:509–528

(node: DoublyLinkedNode<RedisClientType<M, F, S, RESP, TYPE_MAPPING>>)

  }

  #returnClient(node: DoublyLinkedNode<RedisClientType<M, F, S, RESP, TYPE_MAPPING>>) {
    const task = this.#tasksQueue.shift();
    if (task) {
      clearTimeout(task.timeout);
      publish(CHANNELS.POOL_CONNECTION_WAIT, () => ({ clientId: node.value._clientId, waitStartTimestamp: task.waitStartTimestamp }));
      this.#executeTask(node, task.resolve, task.reject, task.fn);
      return;
    }

    this.#clientsInUse.remove(node);
    this.#idleClients.push(node.value);

    // If closing and all tasks are done, signal the drain is complete
    if (this.#isClosing && this.#clientsInUse.length === 0) {
      this.#drainResolve?.();
      return;
    }

    this.#scheduleCleanup();
  }

  cleanupTimeout?: NodeJS.Timeout;