Searched refs:event_tx (Results 1 – 4 of 4) sorted by relevance
| /packages/modules/Bluetooth/system/gd/rust/topshim/facade/src/ |
| D | hfp_service.rs | 30 if let Some(event_tx) = guard_tx.as_ref() { in get_hfp_dispatcher()
31 let txclone = event_tx.clone(); in get_hfp_dispatcher()
50 event_tx: Arc<Mutex<Option<mpsc::Sender<HfpCallbacks>>>>, field
57 let event_tx = Arc::new(Mutex::new(None)); in create() localVariable
58 btif_hfp.lock().unwrap().initialize(get_hfp_dispatcher(btif_hfp.clone(), event_tx.clone())); in create()
60 create_hfp_service(Self { rt, btif_hfp, event_tx }) in create()
185 let mut guard = self.event_tx.lock().unwrap(); in fetch_events()
|
| D | adapter_service.rs | 79 event_tx: mpsc::Sender<BaseCallbacks>, field
94 let (event_tx, rx) = mpsc::channel(10); in create()
96 get_bt_dispatcher(btif_intf.clone(), event_tx.clone()), in create()
103 event_tx, in create()
|
| D | gatt_service.rs | 41 event_tx: mpsc::Sender<GattCallbacks>, field
47 let (event_tx, rx) = mpsc::channel(10); in create()
54 event_tx, in create()
|
| /packages/modules/DnsResolver/doh/tests/doh_frontend/src/ |
| D | dns_https_frontend.rs | 283 let (event_tx, mut event_rx) = mpsc::unbounded_channel::<InternalCommand>(); in worker_thread()
308 event_tx.send(InternalCommand::MaybeWrite{connection_id})?; in worker_thread()
356 event_tx.send(InternalCommand::MaybeWrite{connection_id})?; in worker_thread()
374 event_tx.send(InternalCommand::MaybeWrite{connection_id})?; in worker_thread()
417 … event_tx.send(InternalCommand::MaybeWrite { connection_id: client.connection_id().clone() })?; in worker_thread()
|