Struct async_listen::backpressure::Sender

pub struct Sender { /* fields omitted */ }

The handle that controls backpressure

It can be used to create tokens, changing limit and getting metrics.

See new for more details

Methods

impl Sender

pub fn token(&self) -> Token

Acquire a backpressure token

The token holds one unit of resource

Note: You can always acquire a token, even if capacity limit reached.

pub fn set_limit(&self, new_limit: usize)

Change the limit for the number of connections

If limit is increased it's applied immediately. If limit is lowered, we can't drop connections. So listening stream is paused until there are less then new limit tokens alive (i.e. first dropped tokens may not unblock the stream).

pub fn get_active_tokens(&self) -> usize

Returns the number of currently active tokens

Can return a value larger than limit if tokens are created manually.

This can be used for metrics or debugging. You should not rely on this value being in sync. There is also no way to wake-up when this value is lower than limit, also see has_capacity.

Trait Implementations

impl Clone for Sender

fn clone(&self) -> Sender

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Sender

fn fmt(&self, f: &mut Formatter) -> Result

Formats the value using the given formatter.