Struct Parser 

pub struct Parser { /* private fields */ }

Streaming RESP2 parser.

Feed data incrementally and extract frames as they become available.

Examples

use bytes::Bytes;
use resp_rs::resp2::{Parser, Frame};

let mut parser = Parser::new();
parser.feed(Bytes::from("+HEL"));
assert!(parser.next_frame().unwrap().is_none());

parser.feed(Bytes::from("LO\r\n"));
let frame = parser.next_frame().unwrap().unwrap();
assert_eq!(frame, Frame::SimpleString(Bytes::from("HELLO")));

Implementations

impl Parser

pub fn new() -> Self

Create a new empty parser.

pub fn feed(&mut self, data: Bytes)

Feed data into the parser buffer.

pub fn next_frame(&mut self) -> Result<Option<Frame>, ParseError>

Try to extract the next complete frame.

Returns Ok(None) if there isn’t enough data yet. Returns Err on protocol errors (buffer is cleared).

pub fn buffered_bytes(&self) -> usize

Number of bytes currently buffered.

pub fn clear(&mut self)

Clear the internal buffer.

Trait Implementations

impl Debug for Parser

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for Parser

fn default() -> Parser

Returns the “default value” for a type.