pub async fn tcp_connect_timeout<U>(
        addr: SocketAddr,
        codec: U,
        duration: Duration,
    ) -> io::Result<Self>
    where
        U: Codec + Send + 'static,
    {
        utils::timeout(duration, Self::tcp_connect(addr, codec))
            .await
            .and_then(convert::identity)
    }
/// Connect to a remote TCP server, timing out after duration has passed
Connect to a remote TCP server, timing out after duration has passed
Connect to a remote TCP server timing out after duration has passed
pub async fn tcp_connect_timeout<U>(
        addr: SocketAddr,
        codec: U,
        duration: Duration,
    ) -> io::Result<Self>
    where
        U: Codec + Send + 'static,
    {
        utils::timeout(duration, Self::tcp_connect(addr, codec))
            .await
            .and_then(convert::identity)
    }
pub async fn tcp_connect_timeout < U > ( addr : SocketAddr , codec : U , duration : Duration , ) -> io :: Result < Self > where U : Codec + Send + ' static , { utils :: timeout ( duration , Self :: tcp_connect ( addr , codec ) ) . await . and_then ( convert :: identity ) }
Connect to a remote TCP server, timing out after duration has passed
Connect to a remote TCP server timing out after duration has passed
addr
SocketAddr
codec
U
duration
Duration