Searched refs:ChunkQueue (Results 1 – 3 of 3) sorted by relevance
10 pub(crate) struct ChunkQueue { struct15 impl ChunkQueue { impl17 ChunkQueue { in new()
94 queue: Arc<ChunkQueue>, // read-only287 queue: Arc::new(ChunkQueue::new(queue_size)), in new()432 queue: &Arc<ChunkQueue>, in process_chunks() argument
17 let q = ChunkQueue::new(0); in test_chunk_queue()34 let q = ChunkQueue::new(1); in test_chunk_queue()