Function onEffectRequest

packages/rpc/src/RpcClient.ts:330–417

(
    rpc: Rpc.AnyWithProps,
    middleware: (request: Request<Rpcs>) => Effect.Effect<Request<Rpcs>>,
    span: Span | undefined,
    payload: any,
    headers: Headers.Headers,
    context: Context.Context<never>,
    discard: boolean
  )

  }

  const onEffectRequest = (
    rpc: Rpc.AnyWithProps,
    middleware: (request: Request<Rpcs>) => Effect.Effect<Request<Rpcs>>,
    span: Span | undefined,
    payload: any,
    headers: Headers.Headers,
    context: Context.Context<never>,
    discard: boolean
  ) =>
    Effect.withFiberRuntime<any, any, any>((parentFiber) => {
      if (isShutdown) {
        return Effect.interrupt
      }
      const id = generateRequestId()
      const send = middleware({
        _tag: "Request",
        id,
        tag: rpc._tag as Rpc.Tag<Rpcs>,
        payload,
        traceId: span?.traceId,
        spanId: span?.spanId,
        sampled: span?.sampled,
        headers: Headers.merge(parentFiber.getFiberRef(currentHeaders), headers)
      })
      if (discard) {
        return Effect.flatMap(send, (message) =>
          options.onFromClient({
            message,
            context,
            discard
          }))
      }
      const runtime = Runtime.make({
        context: parentFiber.currentContext,
        fiberRefs: parentFiber.getFiberRefs(),
        runtimeFlags: Runtime.defaultRuntime.runtimeFlags
      })
      let fiber: Fiber.RuntimeFiber<any, any>
      let completed = false
      return Effect.onInterrupt(
        Effect.async<any, any>((resume) => {
          const entry: ClientEntry = {
            _tag: "Effect",
            rpc,
            context,
            resume(exit) {
              completed = true
              resume(exit)
              if (fiber && !fiber.unsafePoll()) {
                parentFiber.currentScheduler.scheduleTask(
                  () => {
                    fiber.unsafeInterruptAsFork(parentFiber.id())
                  },
                  0,
                  fiber
                )
              }
            }