Searched refs:new_stream_rx (Results 1 – 1 of 1) sorted by relevance
34 new_stream_rx: Arc<Mutex<mpsc::Receiver<Arc<Stream>>>>, field76 let (mut new_stream_tx, new_stream_rx) = mpsc::channel(8); in new()116 new_stream_rx: Arc::new(Mutex::new(new_stream_rx)), in new()217 let mut new_stream_rx = self.new_stream_rx.lock().await; in accept() localVariable218 let result = new_stream_rx.recv().await; in accept()