Function runAdaptive

packages/effect/src/unstable/http/HttpClient.ts:1196–1240

()

      }),
      ({ delay }) => {
        const runAdaptive = (): Effect.Effect<
          HttpClientResponse.HttpClientResponse,
          E | RateLimiter.RateLimiterError,
          R
        > => {
          const runRequest = (adaptive: RateLimiter.AdaptiveConsumeResult | undefined) => {
            const request = Effect.matchEffect(effect, {
              onSuccess(response) {
                return Effect.flatMap(inspectResponse(response, adaptive), (retryAfter) => {
                  if (response.status !== 429 || !canRetry) return Effect.succeed(response)
                  return retry(retryAfter)
                })
              },
              onFailure(error) {
                if (isTooManyRequestsHttpClientError(error)) {
                  return Effect.flatMap(
                    inspectResponse(error.reason.response, adaptive),
                    (retryAfter) => canRetry ? retry(retryAfter) : Effect.fail(error)
                  )
                }
                return Effect.fail(error)
              }
            })
            return adaptive === undefined || Duration.isZero(adaptive.delay)
              ? request
              : Effect.delay(request, adaptive.delay)
          }
          if (!adaptiveLearningEnabled) {
            return runRequest(undefined)
          }
          return Effect.flatMap(
            options.limiter.adaptiveConsume({
              key,
              tokens,
              fallbackLimit: current.limit,
              fallbackWindow: current.window
            }),
            (adaptive) => {
              if (!Duration.isZero(adaptive.delay) && adaptive.phase === "cooldown") {
                return Effect.flatMap(Effect.sleep(adaptive.delay), runAdaptive)
              }
              return runRequest(adaptive)
            }
          )
        }
        return Duration.isZero(delay) ? runAdaptive() : Effect.flatMap(Effect.sleep(delay), runAdaptive)
      }
    )