Searched refs:req_tx (Results 1 – 2 of 2) sorted by relevance
35 req_tx: Sender<Request>, field103 self.req_tx.send(Request::Connect { addr }).await.unwrap(); in connect()109 self.req_tx.send(Request::CancelConnect { addr, fut: tx }).await.unwrap(); in cancel_connect()140 let (req_tx, mut req_rx) = channel::<Request>(10); in provide_acl_manager()196 let (req_tx, req_rx) = channel(10); in provide_acl_manager()202 requests: req_tx, in provide_acl_manager()241 AclManager { req_tx, evt_rx: Arc::new(Mutex::new(conn_evt_rx)) } in provide_acl_manager()
76 let (req_tx, mut req_rx) = channel::<Request>(10); in provide_acl_dispatch()77 let req_tx_clone = req_tx.clone(); in provide_acl_dispatch()177 AclDispatch { requests: req_tx } in provide_acl_dispatch()