(request: Envelope.Request<any>, exit: Exit.Exit<any, any>)
| 363 | // make the Replier for the behaviour |
| 364 | const resumes = new Map<Envelope.Request<any>, (exit: Exit.Exit<any, any>) => void>() |
| 365 | const complete = (request: Envelope.Request<any>, exit: Exit.Exit<any, any>) => |
| 366 | Effect.sync(() => { |
| 367 | const resume = resumes.get(request) |
| 368 | if (resume) { |
| 369 | resumes.delete(request) |
| 370 | resume(exit) |
| 371 | } |
| 372 | }) |
| 373 | const replier: Replier<Rpcs> = { |
| 374 | succeed: (request, value) => complete(request, Exit.succeed(value)), |
| 375 | fail: (request, error) => complete(request, Exit.fail(error)), |
no test coverage detected