(exit: Exit.Exit<any, E>)
| 34 | const fiberSet = yield* FiberSet.make<any, WorkerError | E>() |
| 35 | const runFork = Runtime.runFork(runtime) |
| 36 | const onExit = (exit: Exit.Exit<any, E>) => { |
| 37 | if (exit._tag === "Failure" && !Cause.isInterruptedOnly(exit.cause)) { |
| 38 | Deferred.unsafeDone(closeLatch, Exit.die(Cause.squash(exit.cause))) |
| 39 | } |
| 40 | } |
| 41 | ;(WorkerThreads.parentPort ?? process).on("message", (message: Runner.BackingRunner.Message<I>) => { |
| 42 | if (message[0] === 0) { |
| 43 | const result = handler(0, message[1]) |
nothing calls this directly
no test coverage detected