Function handleEncode

packages/rpc/src/RpcServer.ts:588–606

(
    client: Client,
    requestId: RequestId,
    encodeDefect: (u: unknown) => Effect.Effect<unknown, ParseError>,
    collector: Transferable.CollectorService | undefined,
    effect: Effect.Effect<A, ParseError, R>,
    onSuccess: (a: A) => FromServerEncoded
  )

  const clients = new Map<number, Client>()

  const handleEncode = <A, R>(
    client: Client,
    requestId: RequestId,
    encodeDefect: (u: unknown) => Effect.Effect<unknown, ParseError>,
    collector: Transferable.CollectorService | undefined,
    effect: Effect.Effect<A, ParseError, R>,
    onSuccess: (a: A) => FromServerEncoded
  ) =>
    (collector ? Effect.provideService(effect, Transferable.Collector, collector) : effect).pipe(
      Effect.flatMap((a) => send(client.id, onSuccess(a), collector && collector.unsafeClear())),
      Effect.catchAllCause((cause) => {
        client.schemas.delete(requestId)
        const defect = Cause.squash(Cause.map(cause, TreeFormatter.formatErrorSync))
        return Effect.zipRight(
          sendRequestDefect(client, requestId, encodeDefect, defect),
          server.write(client.id, { _tag: "Interrupt", requestId, interruptors: [] })
        )
      })
    )

  const encodeDefect = Schema.encodeSync(Schema.Defect)