(done: Deferred.Deferred<A, E | Cancelled>)
| 62 | : Deferred.done(done, exit).pipe(Effect.asVoid) |
| 63 | |
| 64 | const awaitDone = (done: Deferred.Deferred<A, E | Cancelled>) => |
| 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) |