Struct ConsistentConcurrency

pub struct ConsistentConcurrency { /* private fields */ }

Consistent concurrency strategy increase limits as streams are closed, to keep the number of streams available to peers roughly consistent.

Implementations

impl ConsistentConcurrency

pub fn new(initial_max_bi: u64, initial_max_uni: u64) -> ConsistentConcurrency

Trait Implementations

impl ControlStreamsConcurrency for ConsistentConcurrency

fn on_accept_streams(&mut self, _dir: Dir, _sid: u64) -> Option<u64>

Called back upon accepting a new dir direction streams with stream id sid from peer, all previous inexistent dir direction streams should be opened by peer will also be created.

fn on_end_of_stream(&mut self, dir: Dir, _sid: u64) -> Option<u64>

Called back upon a dir directional stream is ended, whether it is closed normally or reset abnormally.

fn on_streams_blocked(&mut self, _dir: Dir, _max_streams: u64) -> Option<u64>

Called back upon receiving the StreamsBlocked frame, which indicates that the peer is limited to create more dir direction streams.

impl Debug for ConsistentConcurrency

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.