Searched refs:UnboundedReceiver (Results 1 – 11 of 11) sorted by relevance
| /packages/modules/Bluetooth/system/rust/src/gatt/mocks/ |
| D | mock_transport.rs | 7 use tokio::sync::mpsc::{self, unbounded_channel, UnboundedReceiver};
15 pub fn new() -> (Self, UnboundedReceiver<(TransportIndex, AttBuilder)>) { in new()
|
| D | mock_database_callbacks.rs | 15 use tokio::sync::mpsc::{self, unbounded_channel, UnboundedReceiver};
22 pub fn new() -> (Self, UnboundedReceiver<MockCallbackEvents>) { in new()
|
| D | mock_datastore.rs | 14 mpsc::{self, unbounded_channel, UnboundedReceiver},
23 pub fn new() -> (Self, UnboundedReceiver<MockDatastoreEvents>) { in new()
|
| D | mock_callbacks.rs | 10 use tokio::sync::mpsc::{self, unbounded_channel, UnboundedReceiver};
17 pub fn new() -> (Self, UnboundedReceiver<MockCallbackEvents>) { in new()
|
| D | mock_raw_datastore.rs | 14 mpsc::{self, unbounded_channel, UnboundedReceiver},
23 pub fn new() -> (Self, UnboundedReceiver<MockRawDatastoreEvents>) { in new()
|
| /packages/modules/Bluetooth/system/gd/rust/topshim/facade/src/ |
| D | main.rs | 79 async fn async_main(rt: Arc<Runtime>, mut sigint: mpsc::UnboundedReceiver<()>) { in async_main() argument
132 unsafe fn install_sigint() -> mpsc::UnboundedReceiver<()> { in install_sigint()
|
| /packages/modules/Bluetooth/system/rust/tests/ |
| D | gatt_callbacks_test.rs | 17 use tokio::{sync::mpsc::UnboundedReceiver, task::spawn_local, time::Instant};
32 ) -> (Rc<CallbackTransactionManager>, UnboundedReceiver<MockCallbackEvents>) { in initialize_manager_with_connection()
38 async fn pull_trans_id(events_rx: &mut UnboundedReceiver<MockCallbackEvents>) -> TransactionId { in pull_trans_id()
|
| D | gatt_server_test.rs | 46 sync::mpsc::{error::TryRecvError, UnboundedReceiver},
72 fn start_gatt_module() -> (gatt::server::GattModule, UnboundedReceiver<(TransportIndex, AttBuilder)… in start_gatt_module()
83 ) -> UnboundedReceiver<MockDatastoreEvents> { in create_server_and_open_connection()
|
| /packages/modules/Bluetooth/system/rust/src/gatt/server/services/ |
| D | gatt.rs | 178 use tokio::sync::mpsc::{unbounded_channel, UnboundedReceiver};
211 … ) -> (AttDatabaseImpl, SharedBox<AttServerBearer<AttDatabaseImpl>>, UnboundedReceiver<AttBuilder>) in add_connection()
|
| /packages/modules/Bluetooth/system/rust/src/gatt/server/ |
| D | att_server_bearer.rs | 222 use tokio::sync::mpsc::{error::TryRecvError, unbounded_channel, UnboundedReceiver};
257 ) -> (SharedBox<AttServerBearer<TestAttDatabase>>, UnboundedReceiver<AttBuilder>) { in open_connection()
|
| /packages/modules/DnsResolver/doh/tests/doh_frontend/src/ |
| D | dns_https_frontend.rs | 97 command_rx: mpsc::UnboundedReceiver<ControlCommand>,
|