Home
last modified time | relevance | path

Searched refs:RecvError (Results 1 - 8 of 8) sorted by relevance

/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/
H A Derror.rs33 pub struct RecvError; structure names
35 impl Display for RecvError {
41 impl Error for RecvError {} in fmt()
128 use crate::sync::error::{RecvError, RecvTimeoutError, TryRecvError};
137 let recv_err = RecvError; in ut_test_sync_error_display()
H A Dwatch.rs25 use crate::sync::error::{RecvError, SendError};
304 pub fn is_notified(&self) -> Result<bool, RecvError> { in is_notified()
307 return Err(RecvError); in is_notified()
312 pub(crate) fn try_notified(&mut self) -> Option<Result<(), RecvError>> {
320 return Some(Err(RecvError));
339 /// * `Poll::Ready(Err(RecvError))` The sender has been dropped or the
356 pub fn poll_notified(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), RecvError>> { in poll_notified()
384 /// * `Err(RecvError)` The sender has been dropped or the channel is closed.
400 pub async fn notified(&mut self) -> Result<(), RecvError> {
575 use crate::sync::error::RecvError;
[all...]
H A Doneshot.rs53 use super::error::{RecvError, TryRecvError};
116 /// The receiver will fail with a [`RecvError`] if the sender is dropped without
250 /// The receiver will fail with [`RecvError`], if the sender is dropped without
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()
436 None => Err(RecvError), in take_value_sent()
/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/
H A Dmpsc_test.rs18 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()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/unbounded/
H A Dmod.rs21 use crate::sync::error::{RecvError, SendError, TryRecvError};
275 /// * `Poll::Ready(Err(RecvError))` in the following situations: 1. All
293 pub fn poll_recv(&mut self, cx: &mut Context<'_>) -> Poll<Result<T, RecvError>> { in poll_recv()
304 /// * `Err(RecvError)` in the following situations: 1. All senders have been in poll_recv()
319 pub async fn recv(&mut self) -> Result<T, RecvError> { in poll_recv()
H A Dqueue.rs24 use crate::sync::error::{RecvError, SendError, TryRecvError};
219 pub(crate) fn poll_recv(&self, cx: &mut Context<'_>) -> Poll<Result<T, RecvError>> {
222 Err(TryRecvError::Closed) => return Ready(Err(RecvError)),
230 Err(TryRecvError::Closed) => Ready(Err(RecvError)),
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/bounded/
H A Dmod.rs21 use crate::sync::error::{RecvError, SendError, TryRecvError, TrySendError};
393 /// * `Poll::Ready(Err(RecvError))` in the following situations: 1. All
412 pub fn poll_recv(&mut self, cx: &mut Context<'_>) -> Poll<Result<T, RecvError>> { in poll_recv()
423 /// * `Err(RecvError)` in the following situations: 1. All senders have been in poll_recv()
439 pub async fn recv(&mut self) -> Result<T, RecvError> { in poll_recv()
H A Darray.rs24 use crate::sync::error::{RecvError, SendError, TryRecvError, TrySendError};
168 pub(crate) fn poll_recv(&self, cx: &mut Context<'_>) -> Poll<Result<T, RecvError>> {
171 Err(TryRecvError::Closed) => return Ready(Err(RecvError)),
179 Err(TryRecvError::Closed) => Ready(Err(RecvError)),

Completed in 5 milliseconds