MCPcopy Index your code
hub / github.com/Effect-TS/effect / complete

Function complete

packages/cluster/src/Entity.ts:320–327  ·  view source on GitHub ↗
(request: Envelope.Request<any>, exit: Exit.Exit<any, any>)

Source from the content-addressed store, hash-verified

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)),

Callers 1

toLayerMailboxFunction · 0.70

Calls 3

syncMethod · 0.80
resumeFunction · 0.70
getMethod · 0.65

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…