Method init

packages/client/src/plugins/batch.ts:139–181

(options: StandardLinkOptions<T>)

  }

  init(options: StandardLinkOptions<T>): void {
    options.clientInterceptors ??= []

    options.clientInterceptors.push((options) => {
      if (options.request.headers['x-orpc-batch'] !== '1') {
        return options.next()
      }

      return options.next({
        ...options,
        request: {
          ...options.request,
          headers: {
            ...options.request.headers,
            'x-orpc-batch': undefined,
          },
        },
      })
    })

    options.clientInterceptors.push((options) => {
      if (
        this.exclude(options)
        || options.request.body instanceof Blob
        || options.request.body instanceof FormData
        || isAsyncIteratorObject(options.request.body)
        || options.request.signal?.aborted
      ) {
        return options.next()
      }

      const group = this.groups.find(group => group.condition(options))

      if (!group) {
        return options.next()
      }

      return new Promise((resolve, reject) => {
        this.#enqueueRequest(group, options, resolve, reject)
        defer(() => this.#processPendingBatches())
      })
    })
  }

  #enqueueRequest(
    group: BatchLinkPluginGroup<T>,