Lines Matching refs:unordered_queue
38 unordered_queue: RwLock<PendingBaseQueue>, field
57 unordered_queue: Default::default(), in new()
77 let mut unordered_queue = self.unordered_queue.write(); in push() localVariable
78 unordered_queue.push_back(c); in push()
127 let mut unordered_queue = self.unordered_queue.write(); in append_large() localVariable
128 unordered_queue.push_back(chunk); in append_large()
146 let mut unordered_queue = self.unordered_queue.write(); in append_unlimited() localVariable
151 unordered_queue.extend(chunks); in append_unlimited()
169 let unordered_queue = self.unordered_queue.read(); in peek() localVariable
170 return unordered_queue.get(0).cloned(); in peek()
178 let unordered_queue = self.unordered_queue.read(); in peek() localVariable
179 unordered_queue.get(0).cloned() in peek()
197 let mut unordered_queue = self.unordered_queue.write(); in pop() localVariable
198 unordered_queue.pop_front() in pop()
215 let mut unordered_queue = self.unordered_queue.write(); in pop() localVariable
216 unordered_queue.pop_front() in pop()