Function onRequest

packages/rpc/src/RpcClient.ts:288–328

(rpc: Rpc.AnyWithProps)

  })

  const onRequest = (rpc: Rpc.AnyWithProps) => {
    const isStream = RpcSchema.isStreamSchema(rpc.successSchema)
    const middleware = getRpcClientMiddleware(rpc)
    return (payload: any, opts?: {
      readonly asMailbox?: boolean | undefined
      readonly streamBufferSize?: number | undefined
      readonly headers?: Headers.Input | undefined
      readonly context?: Context.Context<never> | undefined
      readonly discard?: boolean | undefined
    }) => {
      const headers = opts?.headers ? Headers.fromInput(opts.headers) : Headers.empty
      const context = opts?.context ?? Context.empty()
      if (!isStream) {
        const onRequest = (span: Span | undefined) =>
          onEffectRequest(
            rpc,
            middleware,
            span,
            rpc.payloadSchema.make ? rpc.payloadSchema.make(payload) : payload,
            headers,
            context,
            opts?.discard ?? false
          )
        return disableTracing ? onRequest(undefined) : Effect.useSpan(
          `${spanPrefix}.${rpc._tag}`,
          { captureStackTrace: false, attributes: options.spanAttributes },
          onRequest
        )
      }
      const mailbox = onStreamRequest(
        rpc,
        middleware,
        rpc.payloadSchema.make ? rpc.payloadSchema.make(payload) : payload,
        headers,
        opts?.streamBufferSize ?? 16,
        context
      )
      if (opts?.asMailbox) return mailbox
      return Stream.unwrapScoped(Effect.map(mailbox, Mailbox.toStream))
    }
  }

  const onEffectRequest = (
    rpc: Rpc.AnyWithProps,