pub fn recv_packet_from_client(&mut self) -> Option<buffer::Buffer> {
        if self.stream_killed == true {
            return None;
        }
        match self
            .rx
            .recv_timeout(time::Duration::from_millis(self.timeout_ms))
        {
            Ok(packet) => Some(packet),
            Err(_) => None,
        }
    }
/// Receives a packet from the client thread
Receives a packet from the client thread
Receives a packet from the client thread
pub fn recv_packet_from_client(&mut self) -> Option<buffer::Buffer> {
        if self.stream_killed == true {
            return None;
        }
        match self
            .rx
            .recv_timeout(time::Duration::from_millis(self.timeout_ms))
        {
            Ok(packet) => Some(packet),
            Err(_) => None,
        }
    }
pub fn recv_packet_from_client ( & mut self ) -> Option < buffer :: Buffer > { if self . stream_killed == true { return None ; } match self . rx . recv_timeout ( time :: Duration :: from_millis ( self . timeout_ms ) ) { Ok ( packet ) => Some ( packet ) , Err ( _ ) => None , } }
Receives a packet from the client thread
Receives a packet from the client thread
&mut self
&mut self