Struct StreamingParser

pub struct StreamingParser { /* private fields */ }

A streaming parser that accumulates bytes until a complete SBUS frame is decoded

This parser is designed for real-world scenarios where data arrives incrementally from serial ports. It handles:

• Partial frame data
• Synchronization recovery
• Mid-stream starts

Example

let mut parser = StreamingParser::new();

// Feed bytes as they arrive
if let Some(packet) = parser.push_byte(0x0F).unwrap() {
    // Won't return a packet yet
}

// Or feed chunks
let data = [0x0F, 0x00, 0x00, /* ... */];
for packet in parser.push_bytes(&data) {
    println!("Got packet: {:?}", packet.unwrap());
}

Implementations

impl StreamingParser

pub const fn new() -> Self

Creates a new streaming parser

pub const fn stats(&self) -> &StreamingStats

Get parser statistics

pub fn reset(&mut self)

Reset the parser state

pub fn push_byte(&mut self, byte: u8) -> Result<Option<SbusPacket>, SbusError>

Push a single byte into the parser

Returns Some(packet) if a complete frame was decoded, None otherwise

pub fn push_bytes<'a>(&'a mut self, data: &'a [u8]) -> StreamingIterator<'a>

Push multiple bytes into the parser

Returns an iterator over successfully decoded packets

Trait Implementations

impl Clone for StreamingParser

fn clone(&self) -> StreamingParser

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for StreamingParser

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

Formats the value using the given formatter.

impl Default for StreamingParser

fn default() -> Self

Returns the “default value” for a type.

impl Format for StreamingParser

where [u8; 25]: Format, StreamingStats: Format,

fn format(&self, f: Formatter<'_>)

Writes the defmt representation of self to fmt.