Lines Matching refs:ordered_queue
39 ordered_queue: RwLock<PendingBaseQueue>, field
58 ordered_queue: Default::default(), in new()
80 let mut ordered_queue = self.ordered_queue.write(); in push() localVariable
81 ordered_queue.push_back(c); in push()
130 let mut ordered_queue = self.ordered_queue.write(); in append_large() localVariable
131 ordered_queue.push_back(chunk); in append_large()
153 let mut ordered_queue = self.ordered_queue.write(); in append_unlimited() localVariable
158 ordered_queue.extend(chunks); in append_unlimited()
172 let ordered_queue = self.ordered_queue.read(); in peek() localVariable
173 return ordered_queue.get(0).cloned(); in peek()
186 let ordered_queue = self.ordered_queue.read(); in peek() localVariable
187 ordered_queue.get(0).cloned() in peek()
200 let mut ordered_queue = self.ordered_queue.write(); in pop() localVariable
201 ordered_queue.pop_front() in pop()
227 let mut ordered_queue = self.ordered_queue.write(); in pop() localVariable
228 ordered_queue.pop_front() in pop()