Searched defs:RecvError (Results 1 – 11 of 11) sorted by relevance
| /external/rust/crates/tokio/src/sync/mpsc/ |
| D | error.rs | 84 pub struct RecvError(()); struct
87 impl fmt::Display for RecvError { implementation
94 impl Error for RecvError {} implementation
|
| /external/rust/crates/tokio/src/sync/ |
| D | watch.rs | 141 pub struct RecvError(pub(super) ()); struct
145 impl fmt::Display for RecvError { implementation
151 impl std::error::Error for RecvError {} implementation
360 pub async fn changed(&mut self) -> Result<(), error::RecvError> { in changed()
386 ) -> Option<Result<(), error::RecvError>> { in maybe_changed()
|
| D | broadcast.rs | 234 pub enum RecvError { enum
246 impl fmt::Display for RecvError { implementation
255 impl std::error::Error for RecvError {} implementation
884 pub async fn recv(&mut self) -> Result<T, RecvError> { in recv() argument
990 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<T, RecvError>> { in poll() argument
|
| D | oneshot.rs | 314 pub struct RecvError(pub(super) ()); struct
328 impl fmt::Display for RecvError { implementation
334 impl std::error::Error for RecvError {} implementation
932 fn poll_recv(&self, cx: &mut Context<'_>) -> Poll<Result<T, RecvError>> { in poll_recv() argument
|
| /external/rust/crates/crossbeam-channel/src/ |
| D | err.rs | 54 pub struct RecvError; struct
282 impl fmt::Display for RecvError { implementation
288 impl error::Error for RecvError {} implementation
|
| D | select.rs | 1232 pub fn recv<T>(mut self, r: &Receiver<T>) -> Result<T, RecvError> { in recv() argument
|
| D | channel.rs | 798 pub fn recv(&self) -> Result<T, RecvError> { in recv() argument
|
| /external/uwb/src/rust/ |
| D | error.rs | 44 RecvError(#[from] oneshot::error::RecvError), enumerator
|
| /external/rust/crates/tokio-stream/src/wrappers/ |
| D | watch.rs | 57 ) -> (Result<(), RecvError>, Receiver<T>) { in make_future() argument
|
| D | broadcast.rs | 40 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/ |
| D | mpsc.rs | 91 pub fn recv(&self) -> Result<T, RecvError> { in recv() argument
|