Home
last modified time | relevance | path

Searched refs:RecvTimeoutError (Results 1 - 6 of 6) sorted by relevance

/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/
H A Derror.rs106 pub enum RecvTimeoutError { enum
113 impl Display for RecvTimeoutError {
116 RecvTimeoutError::Closed => write!(f, "channel is closed"), in fmt()
117 RecvTimeoutError::Timeout => write!(f, "channel receiving timeout"), in fmt()
122 impl Error for RecvTimeoutError {}
128 use crate::sync::error::{RecvError, RecvTimeoutError, TryRecvError};
145 let try_timeout1 = RecvTimeoutError::Closed; in ut_test_sync_error_display()
147 let try_timeout2 = RecvTimeoutError::Timeout; in ut_test_sync_error_display()
/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/
H A Derror.rs44 ScheduleError::new(ErrorKind::Other, std::sync::mpsc::RecvTimeoutError::Timeout); in sdv_schedule_error_new()
H A Dmpsc_test.rs18 use ylong_runtime::sync::error::{RecvError, RecvTimeoutError, TryRecvError, TrySendError};
90 Err(RecvTimeoutError::Timeout) in sdv_unbounded_send_recv_timeout_test()
175 Err(RecvTimeoutError::Timeout) in sdv_bounded_send_timeout_recv_timeout_test()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/unbounded/
H A Dmod.rs28 use crate::sync::error::RecvTimeoutError;
331 /// * `Err(RecvTimeoutError::Closed)` if all senders have been dropped.
332 /// * `Err(RecvTimeoutError::TimeOut)` if receiving timeout has elapsed.
349 pub async fn recv_timeout(&mut self, time: Duration) -> Result<T, RecvTimeoutError> {
351 Ok(res) => res.map_err(|_| RecvTimeoutError::Closed),
352 Err(_) => Err(RecvTimeoutError::Timeout),
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/bounded/
H A Dmod.rs25 use crate::sync::error::{RecvTimeoutError, SendTimeoutError};
451 /// * `Err(RecvTimeoutError::Closed)` if all senders have been dropped.
452 /// * `Err(RecvTimeoutError::TimeOut)` if time limit has been passed.
470 pub async fn recv_timeout(&mut self, time: Duration) -> Result<T, RecvTimeoutError> {
472 Ok(res) => res.map_err(|_| RecvTimeoutError::Closed),
473 Err(_) => Err(RecvTimeoutError::Timeout),
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/
H A Derror.rs242 ScheduleError::new(ErrorKind::Other, std::sync::mpsc::RecvTimeoutError::Timeout); in ut_schedule_error_new()

Completed in 3 milliseconds