Lines Matching refs:RecvTimeoutError
23 use std::sync::mpsc::{RecvError, RecvTimeoutError, TryRecvError};
89 pub fn recv_timeout(&self, timeout: Duration) -> Result<T, RecvTimeoutError> { in recv_timeout() argument
91 cc::RecvTimeoutError::Timeout => RecvTimeoutError::Timeout, in recv_timeout()
92 cc::RecvTimeoutError::Disconnected => RecvTimeoutError::Disconnected, in recv_timeout()
653 Err(RecvTimeoutError::Timeout) in oneshot_single_thread_recv_timeout()
681 Err(RecvTimeoutError::Timeout) => continue, in stress_recv_timeout_two_threads()
682 Err(RecvTimeoutError::Disconnected) => break, in stress_recv_timeout_two_threads()
697 assert_eq!(rx.recv_timeout(timeout), Err(RecvTimeoutError::Timeout)); in recv_timeout_upgrade()
725 Err(RecvTimeoutError::Timeout) => continue, in stress_recv_timeout_shared()
726 Err(RecvTimeoutError::Disconnected) => break, in stress_recv_timeout_shared()
767 Err(RecvTimeoutError::Timeout) in shared_recv_timeout()
1000 Err(RecvTimeoutError::Timeout) in recv_timeout()
1111 Err(RecvTimeoutError::Timeout) => continue, in stress_recv_timeout_two_threads()
1112 Err(RecvTimeoutError::Disconnected) => break, in stress_recv_timeout_two_threads()
1135 Err(RecvTimeoutError::Timeout) => continue, in stress_recv_timeout_shared()
1136 Err(RecvTimeoutError::Disconnected) => break, in stress_recv_timeout_shared()