MCPcopy Create free account
hub / github.com/Effect-TS/effect / complete

Function complete

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

Source from the content-addressed store, hash-verified

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

Callers 3

toLayerQueueFunction · 0.70
Request.tsFile · 0.50
mcpCore.tsFile · 0.50

Calls 3

resumeFunction · 0.70
getMethod · 0.65
syncMethod · 0.45

Tested by

no test coverage detected