(res: Exit.Exit<X, E> | Effect.Blocked<X, E>, index: number)
| 2265 | const processingFiber = runFiber( |
| 2266 | core.async<any, any, any>((resume) => { |
| 2267 | const pushResult = <X, E>(res: Exit.Exit<X, E> | Effect.Blocked<X, E>, index: number) => { |
| 2268 | if (res._op === "Blocked") { |
| 2269 | residual.push(res as core.Blocked) |
| 2270 | } else { |
| 2271 | results.push({ index, exit: res }) |
| 2272 | if (res._op === "Failure" && !interrupted) { |
| 2273 | onInterruptSignal() |
| 2274 | } |
| 2275 | } |
| 2276 | } |
| 2277 | const next = () => { |
| 2278 | if (todos.length > 0) { |
| 2279 | const a = todos.pop()! |
no test coverage detected