Searched refs:queued_outputs (Results 1 – 1 of 1) sorted by relevance
100 queued_outputs: BinaryHeap<OrderWrapper<T::Output>>, field115 queued_outputs: BinaryHeap::new(), in new()127 self.in_progress_queue.len() + self.queued_outputs.len() in len()132 self.in_progress_queue.is_empty() && self.queued_outputs.is_empty() in is_empty()164 if let Some(next_output) = this.queued_outputs.peek_mut() { in poll_next()178 this.queued_outputs.push(output) in poll_next()213 self.in_progress_queue.is_terminated() && self.queued_outputs.is_empty() in is_terminated()