Method #create

packages/client/lib/client/pool.ts:427–444

()

  }

  async #create() {
    const client = this._self.#clientFactory();
    client._setIdentity(ClientRole.POOL_MEMBER, this._self.#identity.id);
    client.on('error', (err: Error) => this.emit('error', err));
    // Track the client as "in use" during connect so it counts toward capacity.
    // If we waited to add it until after connect, the pool would think it doesn't
    // exist yet and could spin up extra clients when multiple tasks queue up.
    const node = this._self.#clientsInUse.push(client);

    try {
      await client.connect();
    } catch (err) {
      this._self.#clientsInUse.remove(node);
      throw err;
    }

    this._self.#returnClient(node);
  }

  execute<T>(fn: PoolTask<M, F, S, RESP, TYPE_MAPPING, T>) {
    return new Promise<Awaited<T>>((resolve, reject) => {