Searched refs:peek (Results 1 – 8 of 8) sorted by relevance
19 let d = q.peek().await; in test_chunk_queue()41 let d = q.peek().await; in test_chunk_queue()
39 pub(crate) async fn peek(&self) -> Option<Box<dyn Chunk + Send + Sync>> { in peek() method
460 if let Some(c) = queue.peek().await { in process_chunks()
286 let c = pq.peek(); in test_pending_queue_push_and_pop()304 let c = pq.peek(); in test_pending_queue_push_and_pop()332 let c = pq.peek(); in test_pending_queue_unordered_wins()340 let c = pq.peek(); in test_pending_queue_unordered_wins()348 let c = pq.peek(); in test_pending_queue_unordered_wins()356 let c = pq.peek(); in test_pending_queue_unordered_wins()382 let c = pq.peek(); in test_pending_queue_fragments()401 let c = pq.peek(); in test_pending_queue_selection_persistence()416 let c = pq.peek(); in test_pending_queue_selection_persistence()
166 pub(crate) fn peek(&self) -> Option<ChunkPayloadData> { in peek() method
291 pub(crate) async fn peek(&self, b: &mut [u8]) -> Result<(usize, Attributes)> { in peek() method
1858 while let Some(c) = self.pending_queue.peek() { in pop_pending_data_chunks_to_send()1899 if let Some(c) = self.pending_queue.peek() { in pop_pending_data_chunks_to_send()
1077 let n = match track.peek(&mut b).await { in start_receiver()