(item)
| 31 | * @param {T} item item |
| 32 | */ |
| 33 | const push = (item) => { |
| 34 | queue.push(item); |
| 35 | if (!processScheduled && processing < concurrency) { |
| 36 | processScheduled = true; |
| 37 | process.nextTick(processQueue); |
| 38 | } |
| 39 | }; |
| 40 | |
| 41 | /** |
| 42 | * Handles completion of a single processor call, propagating the first |
no test coverage detected