Method try_parse

nodedb/src/control/server/resp/codec.rs:146–178

Try to parse a complete RESP frame from the buffer. Returns `Ok(Some(value))` if a complete frame was parsed (consumed from buffer). Returns `Ok(None)` if more data is needed. Returns `Err` on protocol errors.

(&mut self)

    /// Returns `Ok(None)` if more data is needed.
    /// Returns `Err` on protocol errors.
    pub fn try_parse(&mut self) -> io::Result<Option<RespValue>> {
        if self.buf.is_empty() {
            return Ok(None);
        }

        match self.buf[0] {
            b'+' | b'-' | b':' | b'$' | b'*' => {
                let (value, consumed) = match parse_value(&self.buf) {
                    Ok(Some((v, n))) => (v, n),
                    Ok(None) => return Ok(None),
                    Err(e) => return Err(e),
                };
                self.buf.drain(..consumed);
                Ok(Some(value))
            }
            // Inline command: plain text terminated by \r\n or \n.
            _ => {
                if let Some(pos) = find_line_end(&self.buf) {
                    let line = &self.buf[..pos];
                    let parts = parse_inline_command(line);
                    let consumed = if self.buf.get(pos + 1) == Some(&b'\n') {
                        pos + 2
                    } else {
                        pos + 1
                    };
                    self.buf.drain(..consumed);
                    Ok(Some(parts))
                } else {
                    Ok(None) // Need more data.
                }
            }
        }
    }

    /// Number of bytes in the parser buffer (for backpressure).
    pub fn buffered(&self) -> usize {