pub fn recv_timeout<T>(&self, timeout: Duration) -> Result<Option<T>>
    where
        T: for<'de> Deserialize<'de>,
    {
        Ok(
            if let Some((value, position)) = self.recv_timeout_0(Some(timeout))? {
                self.seek(position)?;

                Some(value)
            } else {
                None
            },
        )
    }
/// Attempt to read a message, blocking for up to the specified duration if necessary until one becomes
/// available.
Attempt to read a message, blocking for up to the specified duration if necessary until one becomes
available.
Attempt to read a message blocking for up to the specified duration if necessary until one becomes available .
pub fn recv_timeout<T>(&self, timeout: Duration) -> Result<Option<T>>
    where
        T: for<'de> Deserialize<'de>,
    {
        Ok(
            if let Some((value, position)) = self.recv_timeout_0(Some(timeout))? {
                self.seek(position)?;
                Some(value)
            } else {
                None
            },
        )
    }
pub fn recv_timeout < T > ( & self , timeout : Duration ) -> Result < Option < T > > where T : for < ' de > Deserialize < ' de > , { Ok ( if let Some ( ( value , position ) ) = self . recv_timeout_0 ( Some ( timeout ) ) ? { self . seek ( position ) ? ; Some ( value ) } else { None } , ) }
Attempt to read a message, blocking for up to the specified duration if necessary until one becomes
available.
Attempt to read a message blocking for up to the specified duration if necessary until one becomes available .
&self
timeout
Duration
&self
timeout
Duration