Home
last modified time | relevance | path

Searched defs:RecvError (Results 1 – 10 of 10) sorted by relevance

/external/rust/crates/tokio/src/sync/mpsc/
Derror.rs84 pub struct RecvError(()); struct
87 impl fmt::Display for RecvError { implementation
94 impl Error for RecvError {} implementation
/external/rust/crates/tokio/src/sync/
Dwatch.rs211 pub struct RecvError(pub(super) ()); struct
215 impl fmt::Display for RecvError { implementation
221 impl std::error::Error for RecvError {} implementation
475 pub fn has_changed(&self) -> Result<bool, error::RecvError> { in has_changed()
526 pub async fn changed(&mut self) -> Result<(), error::RecvError> { in changed()
568 ) -> Option<Result<(), error::RecvError>> { in maybe_changed()
Doneshot.rs337 pub struct RecvError(pub(super) ()); struct
351 impl fmt::Display for RecvError { implementation
357 impl std::error::Error for RecvError {} implementation
1059 pub fn blocking_recv(self) -> Result<T, RecvError> { in blocking_recv() argument
1127 fn poll_recv(&self, cx: &mut Context<'_>) -> Poll<Result<T, RecvError>> { in poll_recv() argument
Dbroadcast.rs237 pub enum RecvError { enum
249 impl fmt::Display for RecvError { implementation
258 impl std::error::Error for RecvError {} implementation
1060 pub async fn recv(&mut self) -> Result<T, RecvError> { in recv() argument
1166 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<T, RecvError>> { in poll() argument
/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
Dselect.rs1241 pub fn recv<T>(mut self, r: &Receiver<T>) -> Result<T, RecvError> { in recv() argument
Dchannel.rs812 pub fn recv(&self) -> Result<T, RecvError> { in recv() argument
/external/rust/crates/tokio-stream/src/wrappers/
Dwatch.rs80 ) -> (Result<(), RecvError>, Receiver<T>) { in make_future() argument
Dbroadcast.rs40 async fn make_future<T: Clone>(mut rx: Receiver<T>) -> (Result<T, RecvError>, Receiver<T>) { in make_future() argument
/external/rust/crates/crossbeam-channel/tests/
Dmpsc.rs91 pub fn recv(&self) -> Result<T, RecvError> { in recv() argument