Struct StreamingParser

pub struct StreamingParser<'a> { /* private fields */ }

Streaming YAML parser that processes events on demand

Implementations

impl<'a> StreamingParser<'a>

pub fn new(input: String, config: StreamingConfig) -> StreamingParser<'static>

Create a new streaming parser with traditional scanner

pub fn new_zero_copy(input: &'a str, config: StreamingConfig) -> Self

Create a new streaming parser with zero-copy scanner

pub fn next_batch(&mut self) -> Result<Vec<Event>>

Get the next batch of events

pub fn get_stats(&mut self) -> Option<StreamingStats>

Get current parsing statistics

pub fn has_more_events(&self) -> bool

Check if more events are available

pub fn buffer_size(&self) -> usize

Get the current buffer size

Trait Implementations

impl<'a> Parser for StreamingParser<'a>

fn check_event(&self) -> bool

Check if there are more events available

fn peek_event(&self) -> Result<Option<&Event>>

Peek at the next event without consuming it

fn get_event(&mut self) -> Result<Option<Event>>

Get the next event, consuming it

fn reset(&mut self)

Reset the parser state

fn position(&self) -> Position

Get the current position in the input