rustdtp 0.9.0

Cross-platform networking interfaces for Rust.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41

//! Timeout utilities.

/// Attempt to await an async value within a given timeframe.
macro_rules! timeout {
    ($value:expr, $ms:expr, $msg:expr) => {
        ::tokio::select! {
            x = $value => {
                Ok(x)
            },
            _ = ::tokio::time::sleep(::tokio::time::Duration::from_millis($ms)) => {
                ::core::result::Result::Err(::std::io::Error::new(::std::io::ErrorKind::TimedOut, $msg))
            }
        }
    };
}

/// Attempt to await reading from a socket with the default data read timeout.
macro_rules! data_read_timeout {
    ($value:expr) => {
        super::timeout::timeout!(
            $value,
            $crate::util::DATA_READ_TIMEOUT,
            "timed out waiting for data from socket"
        )
    };
}

/// Attempt to await performing a handshake with the default handshake timeout.
macro_rules! handshake_timeout {
    ($value:expr) => {
        super::timeout::timeout!(
            $value,
            $crate::util::HANDSHAKE_TIMEOUT,
            "timed out waiting for handshake"
        )
    };
}

pub(super) use data_read_timeout;
pub(super) use handshake_timeout;
pub(super) use timeout;