(eff: Effect.Effect<A, E, R>, interruptImmediately = false)
| 2234 | return exits |
| 2235 | } |
| 2236 | const runFiber = <A, E, R>(eff: Effect.Effect<A, E, R>, interruptImmediately = false) => { |
| 2237 | const runnable = core.uninterruptible(graft(eff)) |
| 2238 | const fiber = unsafeForkUnstarted( |
| 2239 | runnable, |
| 2240 | parent, |
| 2241 | parent.currentRuntimeFlags, |
| 2242 | fiberScope.globalScope |
| 2243 | ) |
| 2244 | parent.currentScheduler.scheduleTask( |
| 2245 | () => { |
| 2246 | if (interruptImmediately) { |
| 2247 | fiber.unsafeInterruptAsFork(parent.id()) |
| 2248 | } |
| 2249 | fiber.resume(runnable) |
| 2250 | }, |
| 2251 | 0, |
| 2252 | fiber |
| 2253 | ) |
| 2254 | return fiber |
| 2255 | } |
| 2256 | const onInterruptSignal = () => { |
| 2257 | if (!processAll) { |
| 2258 | target -= todos.length |
no test coverage detected