Struct network_clique::rate_limiting::RateLimitingDialer

pub struct RateLimitingDialer<D> {
    dialer: D,
    rate_limiter: SleepingRateLimiter,
}

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

Fields

dialer: D

rate_limiter: SleepingRateLimiter

Implementations

impl<D> RateLimitingDialer<D>

pub fn new(dialer: D, rate_limiter: SleepingRateLimiter) -> Self

Trait Implementations

impl<D: Clone> Clone for RateLimitingDialer<D>

fn clone(&self) -> RateLimitingDialer<D>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<A, D> Dialer<A> for RateLimitingDialer<D>

where A: Data, D: Dialer<A>, <D::Connection as Splittable>::Sender: Unpin, <D::Connection as Splittable>::Receiver: Unpin,

type Connection = Splitted<RateLimitedAsyncRead<<<D as Dialer<A>>::Connection as Splittable>::Receiver>, <<D as Dialer<A>>::Connection as Splittable>::Sender>

type Error = <D as Dialer<A>>::Error

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

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

Attempt to connect to a peer using the provided addressing information.