Home
last modified time | relevance | path

Searched refs:RecvError (Results 1 – 22 of 22) sorted by relevance

/external/rust/crates/crossbeam-channel/src/
Derr.rs54 pub struct RecvError; struct
282 impl fmt::Display for RecvError { implementation
288 impl error::Error for RecvError {} implementation
301 impl From<RecvError> for TryRecvError {
302 fn from(err: RecvError) -> TryRecvError { in from()
304 RecvError => TryRecvError::Disconnected, in from()
340 impl From<RecvError> for RecvTimeoutError {
341 fn from(err: RecvError) -> RecvTimeoutError { in from()
343 RecvError => RecvTimeoutError::Disconnected, in from()
Dlib.rs365 pub use crate::err::{RecvError, RecvTimeoutError, TryRecvError};
Dselect.rs13 use crate::err::{RecvError, SendError};
1230 pub fn recv<T>(mut self, r: &Receiver<T>) -> Result<T, RecvError> { in recv() argument
1237 res.map_err(|_| RecvError) in recv()
Dchannel.rs13 RecvError, RecvTimeoutError, SendError, SendTimeoutError, TryRecvError, TrySendError,
800 pub fn recv(&self) -> Result<T, RecvError> { in recv() argument
825 .map_err(|_| RecvError) in recv()
Dselect_macro.rs590 let _res = _res.map_err(|_| $crate::RecvError);
625 let _res = _res.map_err(|_| $crate::RecvError);
/external/rust/crates/tokio-stream/src/wrappers/
Dbroadcast.rs2 use tokio::sync::broadcast::error::RecvError;
17 inner: ReusableBoxFuture<(Result<T, RecvError>, Receiver<T>)>,
30 async fn make_future<T: Clone>(mut rx: Receiver<T>) -> (Result<T, RecvError>, Receiver<T>) { in make_future() argument
51 Err(RecvError::Closed) => Poll::Ready(None), in poll_next()
52 Err(RecvError::Lagged(n)) => { in poll_next()
Dwatch.rs9 use tokio::sync::watch::error::RecvError;
52 inner: ReusableBoxFuture<(Result<(), RecvError>, Receiver<T>)>,
57 ) -> (Result<(), RecvError>, Receiver<T>) { in make_future() argument
/external/rust/crates/tokio/src/sync/
Dbroadcast.rs234 pub enum RecvError { enum
246 impl fmt::Display for RecvError { implementation
249 RecvError::Closed => write!(f, "channel closed"), in fmt()
250 RecvError::Lagged(amt) => write!(f, "channel lagged by {}", amt), in fmt()
255 impl std::error::Error for RecvError {} implementation
877 pub async fn recv(&mut self) -> Result<T, RecvError> { in recv() argument
981 type Output = Result<T, RecvError>;
983 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<T, RecvError>> { in poll() argument
989 Err(TryRecvError::Lagged(n)) => return Poll::Ready(Err(RecvError::Lagged(n))), in poll()
990 Err(TryRecvError::Closed) => return Poll::Ready(Err(RecvError::Closed)), in poll()
[all …]
Dwatch.rs142 pub struct RecvError(pub(super) ()); struct
146 impl fmt::Display for RecvError { implementation
152 impl std::error::Error for RecvError {} implementation
258 pub async fn changed(&mut self) -> Result<(), error::RecvError> { in changed() argument
275 pub(crate) fn try_has_changed(&mut self) -> Option<Result<(), error::RecvError>> {
284 ) -> Option<Result<(), error::RecvError>> { in maybe_changed() argument
297 return Some(Err(error::RecvError(()))); in maybe_changed()
Doneshot.rs135 pub struct RecvError(pub(super) ()); struct
149 impl fmt::Display for RecvError { implementation
155 impl std::error::Error for RecvError {} implementation
692 type Output = Result<T, RecvError>;
725 fn poll_recv(&self, cx: &mut Context<'_>) -> Poll<Result<T, RecvError>> { in poll_recv() argument
736 None => Ready(Err(RecvError(()))), in poll_recv()
740 Ready(Err(RecvError(()))) in poll_recv()
756 None => Ready(Err(RecvError(()))), in poll_recv()
777 None => Ready(Err(RecvError(()))), in poll_recv()
/external/rust/crates/tokio/src/sync/mpsc/
Derror.rs58 pub struct RecvError(()); struct
60 impl fmt::Display for RecvError { implementation
66 impl Error for RecvError {} implementation
/external/rust/crates/crossbeam-channel/tests/
Dlist.rs10 use crossbeam_channel::{RecvError, RecvTimeoutError, TryRecvError};
100 assert_eq!(r.recv(), Err(RecvError)); in recv()
200 assert_eq!(r.recv(), Err(RecvError)); in recv_after_disconnect()
230 assert_eq!(r.recv(), Err(RecvError)); in disconnect_wakes_receiver()
251 assert_eq!(r.recv(), Err(RecvError)); in spsc()
Darray.rs10 use crossbeam_channel::{RecvError, RecvTimeoutError, TryRecvError};
111 assert_eq!(r.recv(), Err(RecvError)); in recv()
250 assert_eq!(r.recv(), Err(RecvError)); in recv_after_disconnect()
336 assert_eq!(r.recv(), Err(RecvError)); in disconnect_wakes_receiver()
357 assert_eq!(r.recv(), Err(RecvError)); in spsc()
Dselect_macro.rs12 use crossbeam_channel::{Receiver, RecvError, SendError, Sender, TryRecvError};
1182 recv(r) -> res => drop::<Result<i32, RecvError>>(res), in result_types()
1185 recv(r) -> res => drop::<Result<i32, RecvError>>(res), in result_types()
1189 recv(r) -> res => drop::<Result<i32, RecvError>>(res), in result_types()
1207 recv(r) -> res => drop::<Result<i32, RecvError>>(res), in result_types()
1228 recv(r) -> v => assert_eq!(v, Err(RecvError)), in try_recv()
1260 recv(r) -> v => assert_eq!(v, Err(RecvError)), in recv()
1294 recv(r) -> v => assert_eq!(v, Err(RecvError)), in recv_timeout()
1427 recv(r) -> res => assert_eq!(res, Err(RecvError)), in disconnect_wakes_receiver()
Dzero.rs10 use crossbeam_channel::{RecvError, RecvTimeoutError, TryRecvError};
89 assert_eq!(r.recv(), Err(RecvError)); in recv()
240 assert_eq!(r.recv(), Err(RecvError)); in disconnect_wakes_receiver()
261 assert_eq!(r.recv(), Err(RecvError)); in spsc()
Dmpsc.rs23 use std::sync::mpsc::{RecvError, RecvTimeoutError, TryRecvError};
85 pub fn recv(&self) -> Result<T, RecvError> { in recv() argument
86 self.inner.recv().map_err(|_| RecvError) in recv()
180 let $name = res.map_err(|_| ::std::sync::mpsc::RecvError);
438 assert_eq!(rx.recv(), Err(RecvError)); in oneshot_single_thread_recv_chan_close()
516 assert_eq!(rx.recv(), Err(RecvError)); in oneshot_multi_task_recv_then_close()
569 assert_eq!(rx.recv(), Err(RecvError)); in oneshot_multi_thread_recv_close_stress()
1228 assert_eq!(rx.recv(), Err(RecvError)); in oneshot_single_thread_recv_chan_close()
1321 assert_eq!(rx.recv(), Err(RecvError)); in oneshot_multi_task_recv_then_close()
1374 assert_eq!(rx.recv(), Err(RecvError)); in oneshot_multi_thread_recv_close_stress()
/external/rust/crates/tokio/tests/
Dsync_errors.rs18 is_error::<error::RecvError>(); in oneshot_error_bound()
Dsync_broadcast.rs455 fn is_closed(err: broadcast::error::RecvError) -> bool { in is_closed()
456 matches!(err, broadcast::error::RecvError::Closed) in is_closed()
/external/rust/crates/tokio/src/sync/tests/
Dloom_broadcast.rs2 use crate::sync::broadcast::error::RecvError::{Closed, Lagged};
/external/crosvm/devices/src/virtio/snd/vios_backend/
Dshm_vios.rs20 use std::sync::mpsc::{channel, Receiver, RecvError, Sender};
73 BufferStatusSenderLost(RecvError),
/external/rust/crates/tokio/
DCHANGELOG.md866 - sync: impl `Eq`, `PartialEq` for `oneshot::RecvError` ([#2168]).
/external/crosvm/src/
Dlinux.rs2056 Err(mpsc::RecvError) => { in run_vcpu()