Searched refs:command_rx (Results 1 – 3 of 3) sorted by relevance
| /packages/modules/DnsResolver/doh/dispatcher/ |
| D | driver.rs | 30 command_rx: mpsc::Receiver<Command>, field
45 command_rx: mpsc::Receiver<Command>, in new()
50 command_rx, in new()
65 if let Some(command) = self.command_rx.recv().await { in drive_once()
|
| /packages/modules/DnsResolver/doh/network/ |
| D | driver.rs | 37 command_rx: mpsc::Receiver<Command>, field
95 let (command_tx, command_rx) = mpsc::channel(Self::MAX_BUFFERED_COMMANDS); in new()
100 Self { info, config, connection, status_tx, command_rx, validation, tag_socket }, in new()
107 while let Some(cmd) = self.command_rx.recv().await { in drive()
|
| /packages/modules/DnsResolver/doh/tests/doh_frontend/src/ |
| D | dns_https_frontend.rs | 97 command_rx: mpsc::UnboundedReceiver<ControlCommand>, field
252 let (command_tx, command_rx) = mpsc::unbounded_channel::<ControlCommand>(); in init_worker_thread_params()
260 command_rx, in init_worker_thread_params()
284 let mut command_rx = params.command_rx; in worker_thread() localVariable
398 Some(command) = command_rx.recv() => { in worker_thread()
|