Searched refs:UnboundedReceiver (Results 1 – 5 of 5) sorted by relevance
| /system/bt/gd/rust/hal/src/ |
| D | lib.rs | 48 use tokio::sync::mpsc::{unbounded_channel, UnboundedReceiver, UnboundedSender};
54 pub evt_rx: Arc<Mutex<UnboundedReceiver<EventPacket>>>,
56 pub acl_rx: Arc<Mutex<UnboundedReceiver<AclPacket>>>,
58 pub iso_rx: Arc<Mutex<UnboundedReceiver<IsoPacket>>>,
62 pub cmd_rx: UnboundedReceiver<CommandPacket>,
64 pub acl_rx: UnboundedReceiver<AclPacket>,
66 pub iso_rx: UnboundedReceiver<IsoPacket>,
|
| D | hidl_hal.rs | 9 use tokio::sync::mpsc::{unbounded_channel, UnboundedReceiver, UnboundedSender};
103 mut cmd_rx: UnboundedReceiver<CommandPacket>, in dispatch_outgoing()
104 mut acl_rx: UnboundedReceiver<AclPacket>, in dispatch_outgoing()
105 mut iso_rx: UnboundedReceiver<IsoPacket>, in dispatch_outgoing()
|
| D | rootcanal_hal.rs | 18 use tokio::sync::mpsc::{UnboundedReceiver, UnboundedSender};
133 mut cmd_rx: UnboundedReceiver<CommandPacket>, in dispatch_outgoing()
134 mut acl_rx: UnboundedReceiver<AclPacket>, in dispatch_outgoing()
135 mut iso_rx: UnboundedReceiver<IsoPacket>, in dispatch_outgoing()
|
| D | snoop.rs | 16 use tokio::sync::mpsc::{channel, Receiver, Sender, UnboundedReceiver};
199 async fn consume<T>(rx: &Arc<Mutex<UnboundedReceiver<T>>>) -> Option<T> { in consume()
|
| /system/bt/gd/rust/facade/src/ |
| D | main.rs | 30 async fn async_main(rt: Arc<Runtime>, mut sigint: mpsc::UnboundedReceiver<()>) { in async_main() argument
81 fn install_sigint() -> mpsc::UnboundedReceiver<()> { in install_sigint()
|