Method parse_parse

src/protocol/parser.rs:236–255

(&self, cursor: &mut Cursor<&[u8]>, _length: u32)

    }

    async fn parse_parse(&self, cursor: &mut Cursor<&[u8]>, _length: u32) -> Result<FrontendMessage, ParseError> {
        let statement_name = self.read_cstring(cursor).await?;
        let query = self.read_cstring(cursor).await?;
        let param_count = cursor.read_u16::<BigEndian>()? as usize;

        if param_count > self.max_param_count {
            return Err(ParseError::ProtocolViolation("Too many parameters".to_string()));
        }

        let mut param_types = Vec::with_capacity(param_count);
        for _ in 0..param_count {
            param_types.push(cursor.read_u32::<BigEndian>()? as i32);
        }

        Ok(FrontendMessage::Parse {
            name: statement_name,
            query,
            param_types,
        })
    }

    async fn parse_bind(&self, cursor: &mut Cursor<&[u8]>, _length: u32) -> Result<FrontendMessage, ParseError> {
        let portal_name = self.read_cstring(cursor).await?;