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

Function sendRequestDefect

packages/effect/src/unstable/rpc/RpcServer.ts:648–668  ·  view source on GitHub ↗
(
    client: Client,
    requestId: RequestId,
    encodeDefect: (u: unknown) => Effect.Effect<unknown, Schema.SchemaError>,
    defect: unknown
  )

Source from the content-addressed store, hash-verified

646 )
647
648 const sendRequestDefect = (
649 client: Client,
650 requestId: RequestId,
651 encodeDefect: (u: unknown) => Effect.Effect<unknown, Schema.SchemaError>,
652 defect: unknown
653 ) =>
654 Effect.catchCause(
655 Effect.flatMap(encodeDefect(defect), (encodedDefect) =>
656 send(client.id, {
657 _tag: "Exit",
658 requestId,
659 exit: {
660 _tag: "Failure",
661 cause: [{
662 _tag: "Die",
663 defect: encodedDefect
664 }]
665 }
666 })),
667 (cause) => sendDefect(client, Cause.squash(cause))
668 )
669
670 const sendDefect = (client: Client, defect: unknown) =>
671 Effect.catchCause(

Callers 2

handleEncodeFunction · 0.85
RpcServer.tsFile · 0.85

Calls 2

sendDefectFunction · 0.85
sendFunction · 0.70

Tested by

no test coverage detected