Class RequestExecutor<H, P, S>

constructor

• new RequestExecutor<H = unknown, P = unknown, S = unknown>(
      engine: FetchEngineCore<H, P, S>,
  ): RequestExecutor<H, P, S>

  Type Parameters

  • H = unknown

    Headers type

  • P = unknown

    Params type

  • S = unknown

    Instance state type

  Parameters

  • engine: FetchEngineCore<H, P, S>

  Returns RequestExecutor<H, P, S>

engine

baseUrl

• get baseUrl(): string

  Get base URL from engine options.

  Returns string

defaultType

• get defaultType(): "arrayBuffer" | "blob" | "json" | "text"

  Get default type from engine options.

  Returns "arrayBuffer" | "blob" | "json" | "text"

retryConfig

• get retryConfig(): Required<RetryConfig>

  Get retry configuration from engine options.

  Returns Required<RetryConfig>

determineType

• determineType(
      response: Response,
  ): {
      isJson: boolean;
      isRecognized: boolean;
      type: "arrayBuffer" | "blob" | "json" | "text";
  }

  Determine response type based on content-type header.

  Parameters

  • response: Response

  Returns {
      isJson: boolean;
      isRecognized: boolean;
      type: "arrayBuffer" | "blob" | "json" | "text";
  }

execute

• execute<Res = unknown, Data = unknown, ResHdr = unknown>(
      method: string,
      path: string,
      payloadOrOptions?: Data | CallConfig<H, P, InstanceState>,
      options?: CallConfig<H, P, InstanceState>,
  ): FetchPromise<Res, DictAndT<H>, DictAndT<P>, ResHdr>

  Execute a request with the full lifecycle: timeout, options building, pipeline.

  This is the main entry point called by FetchEngine HTTP methods.

  Type Parameters

  • Res = unknown
  • Data = unknown
  • ResHdr = unknown

  Parameters

  • method: string
  • path: string
  • OptionalpayloadOrOptions: Data | CallConfig<H, P, InstanceState>
  • Optionaloptions: CallConfig<H, P, InstanceState>

  Returns FetchPromise<Res, DictAndT<H>, DictAndT<P>, ResHdr>

executeRequest

• executeRequest<Res, ResHdr = unknown>(
      normalizedOpts: InternalReqOptions<H, P, S>,
      totalTimeout: TimeoutPromise<unknown> | undefined,
  ): Promise<FetchResponse<Res, DictAndT<H>, DictAndT<P>, ResHdr>>

  Executes a request through the 3-phase hook pipeline.

  1. beforeRequest (run) - plugins can modify args or short-circuit with cached response
  2. execute (pipe) - onion-wrapped execution (retry wraps dedupe wraps makeCall)
  3. afterRequest (run) - plugins can modify response or store in cache

  Type Parameters

  • Res
  • ResHdr = unknown

  Parameters

  • normalizedOpts: InternalReqOptions<H, P, S>
  • totalTimeout: TimeoutPromise<unknown> | undefined

  Returns Promise<FetchResponse<Res, DictAndT<H>, DictAndT<P>, ResHdr>>

makeCall

• makeCall<Res, ResHdr = unknown>(
      options: InternalReqOptions<H, P, S>,
  ): Promise<FetchResponse<Res, DictAndT<H>, DictAndT<P>, ResHdr>>

  Makes an API call using fetch and returns enhanced response object.

  Type Parameters

  • Res
  • ResHdr = unknown

  Parameters

  • options: InternalReqOptions<H, P, S>

  Returns Promise<FetchResponse<Res, DictAndT<H>, DictAndT<P>, ResHdr>>

makeRequestOptions

• makeRequestOptions(
      _method: string,
      path: string,
      options: CallConfig<H, P, InstanceState> & {
          attemptTimeout?: number;
          controller: AbortController;
          getTotalTimeoutFired?: () => boolean;
          payload?: unknown;
      },
  ): InternalReqOptions<H, P, S>

  Build normalized request options from method/path/options.

  Parameters

  • _method: string
  • path: string
  • options: CallConfig<H, P, InstanceState> & {
        attemptTimeout?: number;
        controller: AbortController;
        getTotalTimeoutFired?: () => boolean;
        payload?: unknown;
    }

  Returns InternalReqOptions<H, P, S>