()
| 161 | } |
| 162 | |
| 163 | function processQueue() { |
| 164 | if (readyTasks.length === 0 && runningTasks === 0) { |
| 165 | return callback(null, results); |
| 166 | } |
| 167 | while(readyTasks.length && runningTasks < concurrency) { |
| 168 | var run = readyTasks.shift(); |
| 169 | run(); |
| 170 | } |
| 171 | |
| 172 | } |
| 173 | |
| 174 | function addListener(taskName, fn) { |
| 175 | var taskListeners = listeners[taskName]; |
no outgoing calls
no test coverage detected
searching dependent graphs…