(exit: Exit.Exit<any, E>)
| 53 | const services = yield* Effect.context<R>() |
| 54 | const runFork = Effect.runForkWith(services) |
| 55 | const onExit = (exit: Exit.Exit<any, E>) => { |
| 56 | if (exit._tag === "Failure" && !Cause.hasInterruptsOnly(exit.cause)) { |
| 57 | runFork(Effect.logError("unhandled error in worker", exit.cause)) |
| 58 | } |
| 59 | } |
| 60 | const port = WorkerThreads.parentPort ?? process |
| 61 | function onMessage(message: WorkerRunner.PlatformMessage<I>) { |
| 62 | if (message[0] === 0) { |