Method poll_event

perro_source/api_modules/perro_networking/src/tcp.rs:148–157

(&mut self, max_bytes: usize)

            peer: self.peer_string(),
        }
    }

    pub fn read_available(&mut self, max_bytes: usize) -> NetResult<Option<Vec<u8>>> {
        let mut buf = vec![0_u8; max_bytes.max(1)];
        match self.stream.read(&mut buf) {
            Ok(n) => {
                buf.truncate(n);
                Ok(Some(buf))
            }
            Err(err) if err.kind() == io::ErrorKind::WouldBlock => Ok(None),
            Err(err) => Err(NetError::from_io(NetErrorKind::Receive, err)),
        }
    }