Method createPool

test/tools/cmap_spec_runner.ts:320–344

(options)

  }

  createPool(options) {
    this.pool = new ConnectionPool(this.#server, {
      ...this.#poolOptions,
      ...options,
      hostAddress: this.#hostAddress,
      serverApi: process.env.MONGODB_API_VERSION
        ? { version: process.env.MONGODB_API_VERSION }
        : undefined,
      metadata: this.#server.topology.client.options.metadata
    });
    this.#originalServerPool = this.#server.pool;
    this.#server.pool = this.pool;
    ALL_POOL_EVENTS.forEach(eventName => {
      this.pool.on(eventName, event => {
        if (this.#injectPoolStats) {
          event.totalConnectionCount = this.pool.totalConnectionCount;
          event.availableConnectionCount = this.pool.availableConnectionCount;
          event.pendingConnectionCount = this.pool.pendingConnectionCount;
          event.currentCheckedOutCount = this.pool.currentCheckedOutCount;
        }
        this.poolEvents.push(event);
        this.poolEventsEventEmitter.emit('poolEvent');
      });
    });
  }

  closePool() {
    this.#server.pool = this.#originalServerPool;