Searched refs:handler_tx (Results 1 – 3 of 3) sorted by relevance
217 handler_tx: Option<Arc<mpsc::UnboundedSender<Event>>>, field254 if let Some(handler_tx) = &mut self.handler_tx { in insert()255 handler_tx.send(Event { in insert()269 if let Some(handler_tx) = &mut self.handler_tx { in remove()270 handler_tx.send(Event { in remove()388 let (handler_tx, handler_rx) = mpsc::unbounded_channel(); in run()392 let handler_tx = Arc::new(handler_tx); in run() localVariable394 self.handler_tx = Some(Arc::clone(&handler_tx)); in run()411 let agent = Agent::new(Some(handler_tx)); in run()
10 let (handler_tx, mut handler_rx) = tokio::sync::mpsc::unbounded_channel(); in test_agent_process_in_transaction()11 let mut a = Agent::new(Some(Arc::new(handler_tx))); in test_agent_process_in_transaction()36 let (handler_tx, mut handler_rx) = tokio::sync::mpsc::unbounded_channel(); in test_agent_process()37 let mut a = Agent::new(Some(Arc::new(handler_tx))); in test_agent_process()124 let (handler_tx, mut handler_rx) = tokio::sync::mpsc::unbounded_channel(); in test_agent_stop()125 let mut a = Agent::new(Some(Arc::new(handler_tx))); in test_agent_stop()
40 let (handler_tx, mut handler_rx) = tokio::sync::mpsc::unbounded_channel(); in main()53 client.send(&msg, Some(Arc::new(handler_tx))).await?; in main()