Searched refs:pending_concurrency (Results 1 – 1 of 1) sorted by relevance
140 pending_concurrency: VecDeque<u32>, field193 pending_concurrency: VecDeque::new(), in new()314 self.pending_concurrency.push_back(id); in push_pending_concurrency()327 match self.pending_concurrency.pop_front() { in try_consume_pending_concurrency()541 self.pending_concurrency.clear(); in clear_streams_states()