Refactor

lib/Pool.js

@@ -20,20 +20,26 @@ module.exports = class Pool extends EventEmitter {
  this._initialiseTimeout = validateNumber('initialiseTimeout', options, false, 1);
  this._shutdownTimeout = validateNumber('shutdownTimeout', options, false, 1);
  this._state = new State({ maxSize: options.maxSize, minSize: options.minSize });
+
+ this.initialise = this._initialiseTimeout ? this._initialiseWithTimeout : this._initialiseWithoutTimeout;
  }
 
- async initialise() {
+ async _initialiseWithTimeout() {
  this._assertRunning();
  return runInContext(async () => {
  debug('[%d] Initialising', getContextId());
- let resources;
- if (this._initialiseTimeout) {
- const task = this._createInitialiseTask();
- resources = await task.execute();
- } else {
- const task = { isAborted: () => false };
- resources = await this._batchAquire(task);
- }
+ const task = this._createInitialiseTask();
+ const resources = await task.execute();
+ resources.forEach((resource) => this.release(resource));
+ });
+ }
+
+ async _initialiseWithoutTimeout() {
+ this._assertRunning();
+ return runInContext(async () => {
+ debug('[%d] Initialising', getContextId());
+ const task = { isAborted: () => false };
+ const resources = await this._batchAquire(task);
  resources.forEach((resource) => this.release(resource));
  });
  }