(request: I)
| 191 | } |
| 192 | |
| 193 | const execute = (request: I) => |
| 194 | Stream.fromChannel( |
| 195 | Channel.acquireUseRelease( |
| 196 | executeAcquire(request, Mailbox.make<O, E | WorkerError>()), |
| 197 | ({ mailbox }) => Mailbox.toChannel(mailbox), |
| 198 | executeRelease |
| 199 | ) |
| 200 | ) |
| 201 | |
| 202 | const executeEffect = (request: I) => |
| 203 | Effect.acquireUseRelease( |
nothing calls this directly
no test coverage detected