Struct StreamParser 

pub struct StreamParser<'src> { /* private fields */ }

Pull-based streaming parser that yields arena-allocated subtrees.

Implementations

impl<'src> StreamParser<'src>

pub fn from_str(input: &'src str) -> StreamParser<'src>

pub fn from_bytes(input: &'src [u8]) -> Result<StreamParser<'src>, XmlError>

pub fn with_options(self, opts: &ParseOptions) -> StreamParser<'src>

Replace ParseOptions on the underlying reader. Takes a reference (the reader internally clones once — amortized over the whole stream).

pub fn emit_at_depth(self, depth: u32) -> StreamParser<'src>

Emit elements at the given depth. depth = 1 matches direct children of the root. Memory-bounded.

pub fn emit_at_path(self, path: &[&str]) -> StreamParser<'src>

Emit elements whose ancestor chain (from root) matches path exactly. path[0] is the root’s name, path[1] its child, …, path[N-1] the element to emit. Memory-bounded.

pub fn emit_when<F>(self, predicate: F) -> StreamParser<'src>

where F: Fn(&[String]) -> bool + Send + Sync + 'static,

Emit elements whose ancestor chain satisfies predicate. The predicate receives a slice of QNames from root to the just-opened element (inclusive at the end); return true to emit that element’s subtree.

More flexible than emit_at_path / emit_at_depth: handy when the emission criterion is “any <item> regardless of where it appears in the tree” or “any element under <rss> that is itself named entry”.

Memory profile matches the fixed-depth modes — elements above the matching boundary cost only the ancestor stack.

Example

use sup_xml_core::StreamParser;
let xml = r#"<root>
  <section><item>a</item></section>
  <other><item>b</item></other>
</root>"#;
let mut sp = StreamParser::from_str(xml)
    .emit_when(|chain| chain.last().map(String::as_str) == Some("item"));
while sp.next().unwrap().is_some() {}

pub fn next(&mut self) -> Result<Option<Document>, XmlError>

Pull the next emitted subtree. Returns Ok(Some(doc)) for each match, Ok(None) on EOF, Err(_) on parse error.