• Home
  • Raw
  • Download

Lines Matching refs:TryRecvError

23 use std::sync::mpsc::{RecvError, RecvTimeoutError, TryRecvError};
78 pub fn try_recv(&self) -> Result<T, TryRecvError> { in try_recv() argument
80 cc::TryRecvError::Empty => TryRecvError::Empty, in try_recv()
81 cc::TryRecvError::Disconnected => TryRecvError::Disconnected, in try_recv()
479 assert_eq!(rx.try_recv(), Err(TryRecvError::Empty)); in oneshot_single_thread_peek_data()
488 assert_eq!(rx.try_recv(), Err(TryRecvError::Disconnected)); in oneshot_single_thread_peek_close()
489 assert_eq!(rx.try_recv(), Err(TryRecvError::Disconnected)); in oneshot_single_thread_peek_close()
495 assert_eq!(rx.try_recv(), Err(TryRecvError::Empty)); in oneshot_single_thread_peek_open()
912 assert_eq!(rx1.try_recv(), Err(TryRecvError::Empty)); in try_recv_states()
916 assert_eq!(rx1.try_recv(), Err(TryRecvError::Empty)); in try_recv_states()
919 assert_eq!(rx1.try_recv(), Err(TryRecvError::Disconnected)); in try_recv_states()
1278 assert_eq!(rx.try_recv(), Err(TryRecvError::Disconnected)); in oneshot_single_thread_try_recv_closed_with_data()
1284 assert_eq!(rx.try_recv(), Err(TryRecvError::Empty)); in oneshot_single_thread_peek_data()
1293 assert_eq!(rx.try_recv(), Err(TryRecvError::Disconnected)); in oneshot_single_thread_peek_close()
1294 assert_eq!(rx.try_recv(), Err(TryRecvError::Disconnected)); in oneshot_single_thread_peek_close()
1300 assert_eq!(rx.try_recv(), Err(TryRecvError::Empty)); in oneshot_single_thread_peek_open()
1544 assert_eq!(rx1.try_recv(), Err(TryRecvError::Empty)); in try_recv_states()
1548 assert_eq!(rx1.try_recv(), Err(TryRecvError::Empty)); in try_recv_states()
1551 assert_eq!(rx1.try_recv(), Err(TryRecvError::Disconnected)); in try_recv_states()
1787 assert_eq!(rx1.try_recv(), Err(TryRecvError::Empty)); in both_ready()
1788 assert_eq!(rx2.try_recv(), Err(TryRecvError::Empty)); in both_ready()
1831 assert_eq!(rx3.try_recv(), Err(TryRecvError::Empty)); in cloning()
1855 assert_eq!(rx3.try_recv(), Err(TryRecvError::Empty)); in cloning2()