| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/ |
| H A D | watch.rs | 25 use crate::sync::error::{RecvError, SendError};
304 pub fn is_notified(&self) -> Result<bool, RecvError> { in is_notified() argument
307 return Err(RecvError); in is_notified()
312 pub(crate) fn try_notified(&mut self) -> Option<Result<(), RecvError>> { in try_notified() argument
320 return Some(Err(RecvError)); in try_notified()
356 pub fn poll_notified(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), RecvError>> { in poll_notified() argument
400 pub async fn notified(&mut self) -> Result<(), RecvError> { in notified() argument
575 use crate::sync::error::RecvError;
599 assert_eq!(rx.try_notified(), Some(Err(RecvError))); in send_try_notified()
|
| H A D | error.rs | 33 pub struct RecvError; struct
35 impl Display for RecvError { implementation
41 impl Error for RecvError {} implementation
128 use crate::sync::error::{RecvError, RecvTimeoutError, TryRecvError};
137 let recv_err = RecvError; in ut_test_sync_error_display()
|
| H A D | oneshot.rs | 53 use super::error::{RecvError, TryRecvError};
390 type Output = Result<T, RecvError>;
403 CLOSED => Ready(Err(RecvError)), in poll()
430 fn take_value_sent(&self) -> Result<T, RecvError> { in take_value_sent() argument
436 None => Err(RecvError), in take_value_sent()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/unbounded/ |
| H A D | mod.rs | 21 use crate::sync::error::{RecvError, SendError, TryRecvError};
293 pub fn poll_recv(&mut self, cx: &mut Context<'_>) -> Poll<Result<T, RecvError>> { in poll_recv() argument
319 pub async fn recv(&mut self) -> Result<T, RecvError> { in recv() argument
|
| H A D | queue.rs | 24 use crate::sync::error::{RecvError, SendError, TryRecvError};
219 pub(crate) fn poll_recv(&self, cx: &mut Context<'_>) -> Poll<Result<T, RecvError>> { in poll_recv() argument
222 Err(TryRecvError::Closed) => return Ready(Err(RecvError)), in poll_recv()
230 Err(TryRecvError::Closed) => Ready(Err(RecvError)), in poll_recv()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/bounded/ |
| H A D | mod.rs | 21 use crate::sync::error::{RecvError, SendError, TryRecvError, TrySendError};
412 pub fn poll_recv(&mut self, cx: &mut Context<'_>) -> Poll<Result<T, RecvError>> { in poll_recv() argument
439 pub async fn recv(&mut self) -> Result<T, RecvError> { in recv() argument
|
| H A D | array.rs | 24 use crate::sync::error::{RecvError, SendError, TryRecvError, TrySendError};
168 pub(crate) fn poll_recv(&self, cx: &mut Context<'_>) -> Poll<Result<T, RecvError>> { in poll_recv() argument
171 Err(TryRecvError::Closed) => return Ready(Err(RecvError)), in poll_recv()
179 Err(TryRecvError::Closed) => Ready(Err(RecvError)), in poll_recv()
|
| /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};
33 assert_eq!(rx.recv().await, Err(RecvError)); in sdv_unbounded_send_recv_test()
108 assert_eq!(rx.recv().await, Err(RecvError)); in sdv_bounded_send_recv_test()
|