AbstractIntervalRateLimiter

Abstract base class for implementing IntervalRateLimiter.

Constructors

constructor(limit: Int, interval: Duration)

The Duration of each interval.

override val limit: Int

The maximum number of consume invocations allowed for each interval.

suspend override fun consume()

Acquires a permit for a single action. Suspends until the next interval if limit permits have already been acquired in the current interval.

inline suspend fun <T> RateLimiter.consume(action: () -> T): T

Acquires a permit for a single action. Suspends if necessary until the permit would not exceed the maximum frequency of permits.