Function encode_frame

perro_source/api_modules/perro_networking/src/tcp.rs:271–282

(bytes: &[u8])

    /// Try to write all queued bytes without blocking.
    ///
    /// Returns `true` when the queue is empty.
    pub fn flush_pending(&mut self) -> NetResult<bool> {
        while let Some(bytes) = self.tx_queue.front() {
            match self.stream.write(&bytes[self.tx_cursor..]) {
                Ok(0) => {
                    return Err(NetError::new(
                        NetErrorKind::Send,
                        "tcp stream wrote zero bytes",
                    ));
                }
                Ok(n) => {
                    self.tx_cursor += n;
                    if self.tx_cursor == bytes.len() {
                        self.tx_queue.pop_front();
                        self.tx_cursor = 0;