()
| 257 | }, timeout); |
| 258 | |
| 259 | function run() { |
| 260 | if (threadContext.poolEvents.filter(ev => getEventType(ev) === event).length >= count) { |
| 261 | clearTimeout(timeoutId); |
| 262 | return resolve(); |
| 263 | } |
| 264 | |
| 265 | threadContext.poolEventsEventEmitter.once('poolEvent', run); |
| 266 | } |
| 267 | run(); |
| 268 | }); |
| 269 | } |
no test coverage detected