Struct network_clique::rate_limiting::RateLimitingListener

pub struct RateLimitingListener<L> {
    listener: L,
    rate_limiter: SleepingRateLimiter,
}

Implementation of the Listener trait governing all returned Listener::Connection instances by a rate-limiting wrapper.

Fields

listener: L

rate_limiter: SleepingRateLimiter

Implementations

impl<L> RateLimitingListener<L>

pub fn new(listener: L, rate_limiter: SleepingRateLimiter) -> Self

Trait Implementations

impl<L: Listener + Send> Listener for RateLimitingListener<L>

type Connection = Splitted<RateLimitedAsyncRead<<<L as Listener>::Connection as Splittable>::Receiver>, <<L as Listener>::Connection as Splittable>::Sender>

type Error = <L as Listener>::Error

fn accept<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Result<Self::Connection, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Returns the next incoming connection.