Module direct

Direct rate limiters (those that can only hold one state).

Rate limiters based on these types are constructed with the RateLimiter constructors

Structs

RatelimitedSink

A Sink combinator that only allows sending elements when the rate-limiter allows it.

RatelimitedStream

A Stream combinator which will limit the rate of items being received.

Enums

NotKeyed

The “this state store does not use keys” key type.

Traits

DirectStateStore

A trait for state stores that only keep one rate limiting state.

SinkRateLimitExt

Allows converting a futures_util::Sink combinator into a rate-limited sink.

StreamRateLimitExt

Allows converting a futures_util::Stream combinator into a rate-limited stream.