Searched refs:LocalQueueReader (Results 1 – 1 of 1) sorted by relevance
197 struct LocalQueueReader { struct201 impl LocalQueueReader { argument209 impl QueueReader for LocalQueueReader { implementation898 cursor_queue: LocalQueueReader,1870 let cursor_queue = LocalQueueReader::new(queues.remove(&1).unwrap()); in activate()