(
exit: Exit.Exit<
any,
ClusterError.EntityNotAssignedToRunner
>
)
| 73 | fiberRefs: parent.getFiberRefs() |
| 74 | }) |
| 75 | const onExit = ( |
| 76 | exit: Exit.Exit< |
| 77 | any, |
| 78 | ClusterError.EntityNotAssignedToRunner |
| 79 | > |
| 80 | ) => { |
| 81 | if (exit._tag === "Failure") { |
| 82 | resume(exit as any) |
| 83 | } |
| 84 | } |
| 85 | const fiber = Runtime.runFork(runtime)(storage.registerReplyHandler(message)) |
| 86 | fiber.addObserver(onExit) |
| 87 | Runtime.runFork(runtime)(Effect.catchTag( |
nothing calls this directly
no test coverage detected
searching dependent graphs…