Skip to main content

Parser

Struct Parser 

Source
pub struct Parser { /* private fields */ }
Expand description

A streaming parser for RESP3 frames.

This parser allows feeding data in chunks and extracting frames as they become available. It maintains an internal buffer of accumulated data and attempts to parse frames from it.

Implementations§

Source§

impl Parser

Source

pub fn new() -> Self

Creates a new parser with an empty buffer.

Source

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

Feeds a chunk of data into the parser.

The data is appended to the internal buffer.

Source

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

Attempts to extract the next complete frame from the buffer.

Returns Ok(None) if there is not enough data to parse a complete frame. Returns Ok(Some(frame)) on success, consuming the parsed bytes. Returns Err on protocol errors, clearing the buffer.

Source

pub fn buffered_bytes(&self) -> usize

Returns the number of bytes currently in the buffer.

Source

pub fn clear(&mut self)

Clears the internal buffer.

Trait Implementations§

Source§

impl Debug for Parser

Source§

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

Formats the value using the given formatter. Read more
Source§

impl Default for Parser

Source§

fn default() -> Parser

Returns the “default value” for a type. Read more

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.