Method read_bytes

lib/rs/src/protocol/binary.rs:183–210

(&mut self)

    }

    fn read_bytes(&mut self) -> crate::Result<Vec<u8>> {
        let num_bytes = self.transport.read_i32::<BigEndian>()?;

        if num_bytes < 0 {
            return Err(crate::Error::Protocol(ProtocolError::new(
                ProtocolErrorKind::NegativeSize,
                format!("Negative byte array size: {}", num_bytes),
            )));
        }

        if let Some(max_size) = self.config.max_string_size() {
            if num_bytes as usize > max_size {
                return Err(crate::Error::Protocol(ProtocolError::new(
                    ProtocolErrorKind::SizeLimit,
                    format!(
                        "Byte array size {} exceeds maximum allowed size of {}",
                        num_bytes, max_size
                    ),
                )));
            }
        }

        let mut buf = vec![0u8; num_bytes as usize];
        self.transport
            .read_exact(&mut buf)
            .map(|_| buf)
            .map_err(From::from)
    }

    fn read_bool(&mut self) -> crate::Result<bool> {
        let b = self.read_i8()?;