Searched refs:LocalQueueReader (Results 1 – 1 of 1) sorted by relevance
147 struct LocalQueueReader { struct152 impl LocalQueueReader { argument161 impl QueueReader for LocalQueueReader { implementation821 cursor_queue: LocalQueueReader,1378 let cursor_queue = LocalQueueReader::new(cursor_queue, interrupt.clone()); in activate()