Method next

src/master/pool.ts:271–276

(event)

    await new Promise<void>((resolve, reject) => {
      const subscription = this.eventObservable.subscribe({
        next(event) {
          if (event.type === PoolEventType.taskQueueDrained) {
            subscription.unsubscribe()
            resolve(void 0)
          }
        },
        error: reject     // make a pool-wide error reject the completed() result promise
      })
    })