diff --git a/src/cmap/connection_pool.ts b/src/cmap/connection_pool.ts index f9854b392b3..713a51a6d50 100644 --- a/src/cmap/connection_pool.ts +++ b/src/cmap/connection_pool.ts @@ -231,7 +231,7 @@ export class ConnectionPool extends EventEmitter { } this[kWaitQueue].push(waitQueueMember); - setImmediate(() => processWaitQueue(this)); + process.nextTick(processWaitQueue, this); } /** @@ -256,7 +256,7 @@ export class ConnectionPool extends EventEmitter { destroyConnection(this, connection, reason); } - setImmediate(() => processWaitQueue(this)); + process.nextTick(processWaitQueue, this); } /** @@ -429,7 +429,7 @@ function createConnection(pool: ConnectionPool, callback?: Callback) // otherwise add it to the pool for later acquisition, and try to process the wait queue pool[kConnections].push(connection); - setImmediate(() => processWaitQueue(pool)); + process.nextTick(processWaitQueue, pool); }); }