Trait ProductStreamsConcurrencyController

pub trait ProductStreamsConcurrencyController: Send + Sync {
    // Required method
    fn init(
        &self,
        init_max_bidi_streams: u64,
        init_max_uni_streams: u64,
    ) -> Box<dyn ControlStreamsConcurrency>;
}

Required Methods

fn init( &self, init_max_bidi_streams: u64, init_max_uni_streams: u64, ) -> Box<dyn ControlStreamsConcurrency>

Implementors

impl<F, C> ProductStreamsConcurrencyController for F

where F: Fn(u64, u64) -> C + Send + Sync, C: ControlStreamsConcurrency + 'static,