()
| 65 | Deferred.await(done).pipe(Effect.catchTag("RunnerCancelled", (e) => onInterrupt ?? Effect.die(e))) |
| 66 | |
| 67 | const idleIfCurrent = () => |
| 68 | SynchronizedRef.modify(ref, (st) => [st._tag === "Idle" ? idle : Effect.void, st] as const).pipe(Effect.flatten) |
| 69 | |
| 70 | const finishRun = (id: number, done: Deferred.Deferred<A, E | Cancelled>, exit: Exit.Exit<A, E>) => |
| 71 | SynchronizedRef.modify( |