Struct AnnotatedCsvParser 

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

Async streaming parser for InfluxDB annotated CSV.

This parser reads an async byte stream and yields FluxRecords one at a time, without loading the entire response into memory.

Example

use influxdb_stream::parser::AnnotatedCsvParser;
use tokio::io::AsyncRead;

async fn parse<R: AsyncRead + Unpin + Send>(reader: R) {
    let mut parser = AnnotatedCsvParser::new(reader);
    while let Some(record) = parser.next().await.transpose() {
        match record {
            Ok(rec) => println!("Got record: {:?}", rec),
            Err(e) => eprintln!("Parse error: {}", e),
        }
    }
}

Implementations

impl<R: AsyncRead + Unpin + Send> AnnotatedCsvParser<R>

pub fn new(reader: R) -> Self

Create a new parser from an async reader.

pub async fn next(&mut self) -> Result<Option<FluxRecord>>

Parse and return the next record.

Returns:

• Ok(Some(record)) - Successfully parsed a record
• Ok(None) - End of stream (EOF)
• Err(e) - Parse error