Searched refs:fut (Results 1 – 3 of 3) sorted by relevance
| /system/bt/gd/rust/link/src/acl/classic/ |
| D | mod.rs | 78 self.requests.send(ConnectionRequest::Disconnect { reason, fut: tx }).await.unwrap(); in disconnect()
85 Disconnect { reason: DisconnectReason, fut: oneshot::Sender<()> },
109 self.req_tx.send(Request::CancelConnect { addr, fut: tx }).await.unwrap(); in cancel_connect()
117 CancelConnect { addr: Address, fut: oneshot::Sender<()> },
170 Request::CancelConnect { addr, fut } => { in provide_acl_manager()
175 fut.send(()).unwrap(); in provide_acl_manager()
288 ConnectionRequest::Disconnect{reason, fut} => { in run_connection()
290 fut.send(()).unwrap(); in run_connection()
|
| /system/bt/gd/rust/hci/src/ |
| D | lib.rs | 84 fut: oneshot::Sender<EventPacket>, field
99 self.cmd_tx.send(QueuedCommand { cmd, fut: tx }).await?; in send()
185 Some(QueuedCommand{cmd, fut}) if cmd.get_op_code() == this_opcode => { in dispatch()
186 if let Err(e) = fut.send(evt.into()) { in dispatch()
198 Some(QueuedCommand{cmd, fut}) if cmd.get_op_code() == this_opcode => { in dispatch()
199 if let Err(e) = fut.send(evt.into()) { in dispatch()
|
| /system/bt/gd/rust/link/src/acl/ |
| D | core.rs | 57 self.requests.send(Request::Register { handle, bt, fut: tx }).await.unwrap(); in register()
64 Register { handle: u16, bt: Bluetooth, fut: oneshot::Sender<Connection> },
94 Request::Register { handle, bt, fut } => { in provide_acl_dispatch()
120 fut.send(Connection { in provide_acl_dispatch()
|