Searched refs:Event (Results 1 – 2 of 2) sorted by relevance
18 pub type Handler = Option<Arc<mpsc::UnboundedSender<Event>>>;58 pub struct Event { struct63 impl Default for Event { implementation65 Event { in default()135 handler.send(Event { in stop_with_error()154 let e = Event { in process()174 let e = Event { in close()243 let event = Event { in collect()
92 pub(crate) fn handle(&mut self, e: Event) -> Result<()> { in handle()217 handler_tx: Option<Arc<mpsc::UnboundedSender<Event>>>,255 handler_tx.send(Event { in insert()270 handler_tx.send(Event { in remove()281 mut handler_rx: mpsc::UnboundedReceiver<Event>, in start() argument