Function sendRequestDefect

packages/rpc/src/RpcServer.ts:610–631

(
    client: Client,
    requestId: RequestId,
    encodeDefect: (u: unknown) => Effect.Effect<unknown, ParseError>,
    defect: unknown
  )

  const encodeDefect = Schema.encodeSync(Schema.Defect)

  const sendRequestDefect = (
    client: Client,
    requestId: RequestId,
    encodeDefect: (u: unknown) => Effect.Effect<unknown, ParseError>,
    defect: unknown
  ) =>
    Effect.catchAllCause(
      encodeDefect(defect).pipe(Effect.flatMap((encodedDefect) =>
        send(client.id, {
          _tag: "Exit",
          requestId: String(requestId),
          exit: {
            _tag: "Failure",
            cause: {
              _tag: "Die",
              defect: encodedDefect
            }
          }
        })
      )),
      (cause) => sendDefect(client, Cause.squash(cause))
    )

  const sendDefect = (client: Client, defect: unknown) =>
    Effect.catchAllCause(