Searched refs:accept_ch_rx (Results 1 – 2 of 2) sorted by relevance
37 let (accept_ch_rx, done_ch_rx) = &mut *self.ch_rx.lock().await; in accept()40 c = accept_ch_rx.recv() =>{ in accept()104 let (accept_ch_tx, accept_ch_rx) = mpsc::channel(self.backlog); in listen()112 ch_rx: Arc::new(Mutex::new((accept_ch_rx, done_ch_rx.clone()))), in listen()
207 accept_ch_rx: Mutex<mpsc::Receiver<Arc<Stream>>>, field289 let (accept_ch_tx, accept_ch_rx) = mpsc::channel(ACCEPT_CH_SIZE); in new()413 accept_ch_rx: Mutex::new(accept_ch_rx), in new()586 let mut accept_ch_rx = self.accept_ch_rx.lock().await; in accept_stream() localVariable587 accept_ch_rx.recv().await in accept_stream()