(envelope: any)
| 305 | |
| 306 | // create the rpc handlers for the entity |
| 307 | const handler = (envelope: any) => { |
| 308 | return Effect.async<any, any>((resume) => { |
| 309 | mailbox.unsafeOffer(envelope) |
| 310 | resumes.set(envelope, resume) |
| 311 | }) |
| 312 | } |
| 313 | const handlers: Record<string, any> = {} |
| 314 | for (const rpc of this.protocol.requests.keys()) { |
| 315 | handlers[rpc] = handler |
no test coverage detected