Searched refs:txl (Results 1 – 11 of 11) sorted by relevance
113 let txl = self.tx.clone(); in add_media_player() localVariable115 let _ = txl.send(Message::QaAddMediaPlayer(name, browsing_supported)).await; in add_media_player()119 let txl = self.tx.clone(); in rfcomm_send_msc() localVariable121 let _ = txl.send(Message::QaRfcommSendMsc(dlci, addr)).await; in rfcomm_send_msc()125 let txl = self.tx.clone(); in fetch_discoverable_mode() localVariable127 let _ = txl.send(Message::QaFetchDiscoverableMode).await; in fetch_discoverable_mode()131 let txl = self.tx.clone(); in fetch_connectable() localVariable133 let _ = txl.send(Message::QaFetchConnectable).await; in fetch_connectable()137 let txl = self.tx.clone(); in set_connectable() localVariable139 let _ = txl.send(Message::QaSetConnectable(mode)).await; in set_connectable()[all …]
164 let txl = self.tx.clone(); in on_server_registered() localVariable166 let _ = txl.send(Message::Dis(ServiceCallbacks::Registered(status, server_id))).await; in on_server_registered()171 let txl = self.tx.clone(); in on_service_added() localVariable173 let _ = txl.send(Message::Dis(ServiceCallbacks::ServiceAdded(status, service))).await; in on_service_added()185 let txl = self.tx.clone(); in on_characteristic_read_request() localVariable187 let _ = txl in on_characteristic_read_request()
718 let txl = self.tx.clone(); in trigger_update_connectable_mode() localVariable720 let _ = txl.send(Message::TriggerUpdateConnectableMode).await; in trigger_update_connectable_mode()824 let txl = self.tx.clone(); in toggle_enabled_profiles() localVariable831 let _ = txl.send(Message::HidHostEnable).await; in toggle_enabled_profiles()847 let txl = sdptx.clone(); in init_profiles() localVariable849 let _ = txl.send(Message::Sdp(cb)).await; in init_profiles()858 let txl = hhtx.clone(); in init_profiles() localVariable860 let _ = txl.send(Message::HidHost(cb)).await; in init_profiles()1540 let txl = tx.clone(); in get_bt_dispatcher() localVariable1542 let _ = txl.send(Message::Base(cb)).await; in get_bt_dispatcher()[all …]
815 let txl = self.tx.clone(); in dispatch_csis_callbacks() localVariable817 let _ = txl in dispatch_csis_callbacks()1259 fn disconnect_device(txl: Sender<Message>, addr: RawAddress) { in disconnect_device()1262 let _ = txl.send(Message::DisconnectDevice(device)).await; in disconnect_device()1874 let txl = self.tx.clone(); in uhid_create() localVariable1885 txl.blocking_send(Message::UHidTelephonyUseCallback(addr, false)) in uhid_create()1889 txl.blocking_send(Message::UHidTelephonyUseCallback(addr, true)) in uhid_create()1893 txl.blocking_send(Message::UHidHfpOutputCallback( in uhid_create()2167 txl: &Sender<Message>, in wait_retry()2184 let _ = txl.send(Message::Media(MediaActions::Connect(*addr))).await; in wait_retry()[all …]
236 let txl = api_tx.clone(); in dispatch() localVariable238 let _ = txl.send(APIMessage::ShutDown).await; in dispatch()284 let txl = tx.clone(); in dispatch() localVariable287 let _ = txl in dispatch()
322 let txl = self.tx.clone(); in resume() localVariable339 let _unused: Option<()> = txl in resume()349 txl.send(Message::AudioReconnectOnResumeComplete).await.ok(); in resume()
226 let txl = self.tx.clone(); in set_allowed_services() localVariable228 let _ = txl.send(Message::AdminPolicyChanged).await; in set_allowed_services()
565 let txl = self.tx.clone(); in trigger_update_connectable_mode() localVariable567 let _ = txl.send(Message::TriggerUpdateConnectableMode).await; in trigger_update_connectable_mode()
1963 let txl = self.tx.clone(); in on_advertising_set_started() localVariable1970 let _ = txl in on_advertising_set_started()
291 let txl = tx.clone(); in handle_sigterm() localVariable294 let _ = txl.send(Message::InterfaceShutdown).await; in handle_sigterm()304 let txl = tx.clone(); in handle_sigterm() localVariable307 let _ = txl.send(Message::Cleanup).await; in handle_sigterm()
495 let txl = hci_tx.clone(); in configure_hci() localVariable499 let _ = txl in configure_hci()