Struct AsyncXmlStream 

pub struct AsyncXmlStream<R: AsyncRead + Unpin> { /* private fields */ }

Async streaming XML parser

This stream yields Result<StreamItem, String> as items are parsed. It uses Tokio’s async I/O for non-blocking operations.

Implementation Note

This implementation reads all data into memory first, then parses it synchronously and yields items one at a time. For true streaming with backpressure, a more sophisticated implementation using quick-xml’s async features would be needed.

Implementations

impl<R: AsyncRead + Unpin> AsyncXmlStream<R>

pub fn new(reader: R, config: StreamConfig) -> Result<Self, String>

Create a new async XML stream

pub fn position(&self) -> StreamPosition

Get the current stream position for progress tracking

Returns information about bytes processed and items parsed. Useful for progress bars and error reporting.

pub async fn next(&mut self) -> Option<Result<StreamItem, String>>

Async version of next() - yields the next parsed item