Function handleRequest

packages/rpc/src/RpcServer.ts:218–354

(
    requestFiber: Fiber.RuntimeFiber<any, any>,
    client: Client,
    request: Request<Rpcs>
  )

  }

  const handleRequest = (
    requestFiber: Fiber.RuntimeFiber<any, any>,
    client: Client,
    request: Request<Rpcs>
  ): Effect.Effect<void> => {
    if (client.fibers.has(request.id)) {
      return Effect.flatMap(
        Fiber.await(client.fibers.get(request.id)!),
        () => handleRequest(requestFiber, client, request)
      )
    }
    const rpc = group.requests.get(request.tag) as any as Rpc.AnyWithProps
    const entry = context.unsafeMap.get(rpc?.key) as Rpc.Handler<Rpcs["_tag"]>
    if (!rpc || !entry) {
      const write = Effect.catchAllDefect(
        options.onFromServer({
          _tag: "Exit",
          clientId: client.id,
          requestId: request.id,
          exit: Exit.die(`Unknown request tag: ${request.tag}`)
        }),
        (defect) => sendDefect(client, defect)
      )
      if (!client.ended || client.fibers.size > 0) return write
      return Effect.zipRight(write, endClient(client))
    }
    const isStream = RpcSchema.isStreamSchema(rpc.successSchema)
    const result = entry.handler(request.payload, {
      clientId: client.id,
      headers: request.headers
    })

    // if the handler requested forking, then we skip the concurrency control
    const isWrapper = Rpc.isWrapper(result)
    const isFork = isWrapper && result.fork
    const isUninterruptible = isWrapper && result.uninterruptible
    // unwrap the fork data type
    const streamOrEffect = isWrapper ? result.value : result
    const handler = applyMiddleware(
      rpc,
      context,
      client.id,
      request.payload,
      request.headers,
      isStream
        ? streamEffect(client, request, streamOrEffect)
        : streamOrEffect as Effect.Effect<any>
    )
    let responded = false
    let effect = Effect.matchCauseEffect(
      isUninterruptible ? handler : Effect.interruptible(handler),
      {
        onSuccess: (value) => {
          responded = true
          return options.onFromServer({
            _tag: "Exit",
            clientId: client.id,
            requestId: request.id,