(request: Envelope.Request<any>, exit: Exit.Exit<any, any>)
| 318 | // make the Replier for the behaviour |
| 319 | const resumes = new Map<Envelope.Request<any>, (exit: Exit.Exit<any, any>) => void>() |
| 320 | const complete = (request: Envelope.Request<any>, exit: Exit.Exit<any, any>) => |
| 321 | Effect.sync(() => { |
| 322 | const resume = resumes.get(request) |
| 323 | if (resume) { |
| 324 | resumes.delete(request) |
| 325 | resume(exit) |
| 326 | } |
| 327 | }) |
| 328 | const replier: Replier<Rpcs> = { |
| 329 | succeed: (request, value) => complete(request, Exit.succeed(value)), |
| 330 | fail: (request, error) => complete(request, Exit.fail(error)), |
no test coverage detected
searching dependent graphs…