Searched refs:PendingQueue (Results 1 – 7 of 7) sorted by relevance
28 pub(crate) struct PendingQueue { struct46 impl Default for PendingQueue { argument48 PendingQueue::new() in default()52 impl PendingQueue { implementation
277 let pq = PendingQueue::new(); in test_pending_queue_push_and_pop()321 let pq = PendingQueue::new(); in test_pending_queue_unordered_wins()371 let pq = PendingQueue::new(); in test_pending_queue_fragments()398 let pq = PendingQueue::new(); in test_pending_queue_selection_persistence()430 let pq = PendingQueue::new(); in test_pending_queue_append()
83 Arc::new(PendingQueue::new()), in test_stream()157 Arc::new(PendingQueue::new()), in test_poll_stream()
7 use crate::queue::pending_queue::PendingQueue;72 pub(crate) pending_queue: Arc<PendingQueue>,121 pending_queue: Arc<PendingQueue>, in new() argument
8 * Limit the bytes in the PendingQueue to avoid packets accumulating there uncontrollably [#367](htt…
34 use crate::queue::pending_queue::PendingQueue;
46 pending_queue: Arc<PendingQueue>,130 pending_queue: Arc::new(PendingQueue::new()), in new()