Searched defs:update_queue (Results 1 – 3 of 3) sorted by relevance
416 update_queue: Mutex<VecDeque<Pin<Arc<Mutex<SockState>>>>>, field481 let mut update_queue = self.update_queue.lock().unwrap(); in update_sockets_events() localVariable503 let mut update_queue = self.update_queue.lock().unwrap(); in feed_events() localVariable625 let mut update_queue = self.update_queue.lock().unwrap(); localVariable
195 UpdateQueue* update_queue; member255 UpdateQueue update_queue; in StreamAggregatedResources() local361 UpdateQueue* update_queue, in ProcessRequest()
98 UpdateQueue* update_queue) { in MaybeSubscribe()