Trait Handler 

pub trait Handler<C>
where
    Self: Sized + Stream<Item = C>,
    C: Channel,
{
    // Provided methods
    fn max_channels_per_key<K, KF>(
        self,
        n: u32,
        keymaker: KF,
    ) -> ChannelFilter<Self, K, KF>
       where K: Display + Eq + Hash + Clone + Unpin,
             KF: Fn(&C) -> K { ... }
    fn max_concurrent_requests_per_channel(
        self,
        n: usize,
    ) -> ThrottlerStream<Self> { ... }
}

A utility trait enabling a stream to fluently chain a request handler.

Provided Methods

fn max_channels_per_key<K, KF>( self, n: u32, keymaker: KF, ) -> ChannelFilter<Self, K, KF>

where K: Display + Eq + Hash + Clone + Unpin, KF: Fn(&C) -> K,

Enforces channel per-key limits.

fn max_concurrent_requests_per_channel(self, n: usize) -> ThrottlerStream<Self>

Caps the number of concurrent requests per channel.

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors

impl<S, C> Handler<C> for S

where S: Sized + Stream<Item = C>, C: Channel,