pub async fn recv(mut self, timeout: Duration) -> SessionResult<(Chan<P, E, R>, T)> {
        match read_chan(&mut self, timeout).await {
            Ok(v) => Ok((self.cast(), v)),
            Err(e) => {
                close_chan(self);
                Err(e)
            }
        }
    }
/// Receives a value of type `T` from the channel. Returns a tuple
/// containing the resulting channel and the received value.
Receives a value of type `T` from the channel. Returns a tuple
containing the resulting channel and the received value.
Receives a value of type ` T ` from the channel . Returns a tuple containing the resulting channel and the received value .
pub async fn recv(mut self, timeout: Duration) -> SessionResult<(Chan<P, E, R>, T)> {
        match read_chan(&mut self, timeout).await {
            Ok(v) => Ok((self.cast(), v)),
            Err(e) => {
                close_chan(self);
                Err(e)
            }
        }
    }
pub async fn recv ( mut self , timeout : Duration ) -> SessionResult < ( Chan < P , E , R > , T ) > { match read_chan ( & mut self , timeout ) . await { Ok ( v ) => Ok ( ( self . cast ( ) , v ) ) , Err ( e ) => { close_chan ( self ) ; Err ( e ) } } }
Receives a value of type `T` from the channel.
Receives a value of type ` T ` from the channel .
mut self
timeout
Duration