Skip to main content

RateConfigStream

Type Alias RateConfigStream 

Source
type RateConfigStream = Map<Fuse<Receiver<StreamRateLimit>>, fn(StreamRateLimit) -> RateLimitedWriterConfig>;
Expand description

A stream of RateLimitedWriterConfig used to update a DynamicRateLimitedWriter.

Unfortunately we need to store the result of a StreamExt::map and StreamExt::fuse in DataWriter, which leaves us with this ugly type. We use a type alias to make DataWriter a little nicer.

Aliased Typeยง

struct RateConfigStream { /* private fields */ }