(exit: Exit.Exit<any, E>)
| 52 | const trackFiber = Fiber.runIn(scope) |
| 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>) { |
nothing calls this directly
no test coverage detected
searching dependent graphs…