(name)
| 6515 | exports.queuecache = {}; |
| 6516 | |
| 6517 | function queue_next(name) { |
| 6518 | |
| 6519 | var item = exports.queuecache[name]; |
| 6520 | if (!item) |
| 6521 | return; |
| 6522 | |
| 6523 | item.running--; |
| 6524 | |
| 6525 | if (item.running < 0) |
| 6526 | item.running = 0; |
| 6527 | |
| 6528 | if (item.pending.length) { |
| 6529 | var fn = item.pending.shift(); |
| 6530 | if (fn) { |
| 6531 | item.running++; |
| 6532 | setImmediate(queue_next_callback, fn, name); |
| 6533 | } else |
| 6534 | item.running = 0; |
| 6535 | } |
| 6536 | } |
| 6537 | |
| 6538 | function queue_next_callback(fn, name) { |
| 6539 | fn(() => queue_next(name)); |
no outgoing calls
no test coverage detected