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 */ }