Searched defs:Streams (Results 1 – 2 of 2) sorted by relevance
128 pub(crate) struct Streams { struct137 max_concurrent_streams: u32,138 current_concurrent_streams: u32,139 flow_control: FlowControl,140 pending_concurrency: VecDeque<u32>,141 pending_stream_window: HashSet<u32>,142 pending_conn_window: VecDeque<u32>,143 pending_send: VecDeque<u32>,144 window_updating_streams: VecDeque<u32>,178 impl Streams { implementation
438 pub(crate) fn new(streams: Streams, shutdown: Arc<AtomicBool>) -> Self { in new()