Searched refs:RecvTimeoutError (Results 1 – 6 of 6) sorted by relevance
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/ |
| H A D | error.rs | 106 pub enum RecvTimeoutError {
113 impl Display for RecvTimeoutError {
116 RecvTimeoutError::Closed => write!(f, "channel is closed"),
117 RecvTimeoutError::Timeout => write!(f, "channel receiving timeout"),
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()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/unbounded/ |
| H A D | mod.rs | 28 use crate::sync::error::RecvTimeoutError;
349 pub async fn recv_timeout(&mut self, time: Duration) -> Result<T, RecvTimeoutError> { in recv_timeout() argument
351 Ok(res) => res.map_err(|_| RecvTimeoutError::Closed), in recv_timeout()
352 Err(_) => Err(RecvTimeoutError::Timeout), in recv_timeout()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/bounded/ |
| H A D | mod.rs | 25 use crate::sync::error::{RecvTimeoutError, SendTimeoutError};
470 pub async fn recv_timeout(&mut self, time: Duration) -> Result<T, RecvTimeoutError> { in recv_timeout() argument
472 Ok(res) => res.map_err(|_| RecvTimeoutError::Closed), in recv_timeout()
473 Err(_) => Err(RecvTimeoutError::Timeout), in recv_timeout()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| H A D | mpsc_test.rs | 18 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()
|
| H A D | error.rs | 44 ScheduleError::new(ErrorKind::Other, std::sync::mpsc::RecvTimeoutError::Timeout); in sdv_schedule_error_new()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/ |
| H A D | error.rs | 242 ScheduleError::new(ErrorKind::Other, std::sync::mpsc::RecvTimeoutError::Timeout); in ut_schedule_error_new()
|