Function sendDefect

packages/rpc/src/RpcServer.ts:405–415

(client: Client, defect: unknown)

  }

  const sendDefect = (client: Client, defect: unknown) =>
    Effect.suspend(() => {
      const shouldEnd = client.ended && client.fibers.size === 0
      const write = options.onFromServer({
        _tag: "Defect",
        clientId: client.id,
        defect
      })
      if (!shouldEnd) return write
      return Effect.zipRight(write, endClient(client))
    })

  return identity<RpcServer<Rpcs>>({
    write,