Home
last modified time | relevance | path

Searched refs:command_rx (Results 1 – 3 of 3) sorted by relevance

/packages/modules/DnsResolver/doh/dispatcher/
Ddriver.rs30 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/
Ddriver.rs37 command_rx: mpsc::Receiver<Command>, field
103 let (command_tx, command_rx) = mpsc::channel(Self::MAX_BUFFERED_COMMANDS); in new()
107 Self { info, config, connection, status_tx, command_rx, validation, tag_socket }, in new()
114 while let Some(cmd) = self.command_rx.recv().await { in drive()
/packages/modules/DnsResolver/tests/doh/src/
Ddns_https_frontend.rs98 command_rx: mpsc::UnboundedReceiver<ControlCommand>, field
245 let (command_tx, command_rx) = mpsc::unbounded_channel::<ControlCommand>(); in init_worker_thread_params()
253 command_rx, in init_worker_thread_params()
277 let mut command_rx = params.command_rx; in worker_thread() localVariable
389 Some(command) = command_rx.recv() => { in worker_thread()