Searched refs:cstream (Results 1 – 1 of 1) sorted by relevance
842 let cstream = stream.clone(); in listening_task() localVariable848 match time::timeout(timeout, cstream.readable()).await { in listening_task()855 cstream.readable().await.is_ok() in listening_task()877 let rawfd = cstream.as_raw_fd(); in listening_task()880 cstream.try_io(tokio::io::Interest::READABLE, || { in listening_task()