()
| 2254 | return fiber |
| 2255 | } |
| 2256 | const onInterruptSignal = () => { |
| 2257 | if (!processAll) { |
| 2258 | target -= todos.length |
| 2259 | todos = [] |
| 2260 | } |
| 2261 | interrupted = true |
| 2262 | interruptAll() |
| 2263 | } |
| 2264 | const stepOrExit = batching ? core.step : core.exit |
| 2265 | const processingFiber = runFiber( |
| 2266 | core.async<any, any, any>((resume) => { |
no test coverage detected