Struct CsvWriter 

pub struct CsvWriter {
    writer: BufWriter<File>,
    headers_written: bool,
}

Async CSV writer that writes streaming data

Fields

writer: BufWriter<File>

headers_written: bool

Implementations

impl CsvWriter

pub async fn from_file(file_path: &PathBuf) -> Result<Self, String>

Create a new CSV writer

pub async fn write_headers(&mut self, headers: &[String]) -> Result<(), String>

Write headers if not already written

pub async fn write_row( &mut self, row: &DataRow, headers: &[String], ) -> Result<(), String>

Write a single data row

pub async fn write_stream<S>( &mut self, stream: S, headers: &[String], ) -> Result<(), String>

where S: Stream<Item = Result<DataRow, String>> + Unpin,

Write streaming data

pub async fn finish(self) -> Result<(), String>

Flush and close the writer