(done: Deferred.Deferred<A, E | Cancelled>, exit: Exit.Exit<A, E>)
| 57 | } |
| 58 | |
| 59 | const complete = (done: Deferred.Deferred<A, E | Cancelled>, exit: Exit.Exit<A, E>) => |
| 60 | Exit.isFailure(exit) && Cause.hasInterruptsOnly(exit.cause) |
| 61 | ? Deferred.fail(done, new Cancelled()).pipe(Effect.asVoid) |
| 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))) |
no test coverage detected