Home
last modified time | relevance | path

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

/external/rust/android-crates-io/crates/crossbeam-channel/src/
Derr.rs75 pub enum RecvTimeoutError { enum
327 impl fmt::Display for RecvTimeoutError { implementation
336 impl error::Error for RecvTimeoutError {} implementation
338 impl From<RecvError> for RecvTimeoutError { implementation
339 fn from(err: RecvError) -> RecvTimeoutError { in from()
346 impl RecvTimeoutError { implementation
Dchannel.rs877 pub fn recv_timeout(&self, timeout: Duration) -> Result<T, RecvTimeoutError> { in recv_timeout() argument
923 pub fn recv_deadline(&self, deadline: Instant) -> Result<T, RecvTimeoutError> { in recv_deadline() argument
/external/rust/android-crates-io/crates/tokio/tests/
Drt_metrics.rs86 fn try_block_threaded(rt: &Runtime) -> Result<Vec<mpsc::Sender<()>>, mpsc::RecvTimeoutError> { in try_block_threaded()
/external/rust/android-crates-io/crates/crossbeam-channel/src/flavors/
Dnever.rs38 pub(crate) fn recv(&self, deadline: Option<Instant>) -> Result<T, RecvTimeoutError> { in recv() argument
Dat.rs62 pub(crate) fn recv(&self, deadline: Option<Instant>) -> Result<Instant, RecvTimeoutError> { in recv() argument
Dtick.rs59 pub(crate) fn recv(&self, deadline: Option<Instant>) -> Result<Instant, RecvTimeoutError> { in recv() argument
Dzero.rs294 pub(crate) fn recv(&self, deadline: Option<Instant>) -> Result<T, RecvTimeoutError> { in recv() argument
Darray.rs397 pub(crate) fn recv(&self, deadline: Option<Instant>) -> Result<T, RecvTimeoutError> { in recv() argument
Dlist.rs459 pub(crate) fn recv(&self, deadline: Option<Instant>) -> Result<T, RecvTimeoutError> { in recv() argument
/external/rust/android-crates-io/crates/crossbeam-channel/tests/
Dmpsc.rs91 pub fn recv_timeout(&self, timeout: Duration) -> Result<T, RecvTimeoutError> { in recv_timeout() argument