Struct StreamingTableFormatter 

pub struct StreamingTableFormatter<'w> {
    columns: Vec<CqlColumn>,
    colorizer: &'w CqlColorizer,
    writer: &'w mut dyn Write,
    first_page_buffer: Vec<CqlRow>,
    page_size: usize,
    header_written: bool,
    col_widths: Vec<usize>,
    row_count: usize,
    expanded: bool,
}

A streaming table formatter that computes column widths from the first page of results and then formats subsequent rows incrementally.

Fields

columns: Vec<CqlColumn>

colorizer: &'w CqlColorizer

writer: &'w mut dyn Write

first_page_buffer: Vec<CqlRow>

Buffer for first-page rows used to compute column widths

page_size: usize

Maximum number of rows to buffer for width computation

header_written: bool

Whether the header has been written (first page flushed)

col_widths: Vec<usize>

Computed column widths (set after first page flush)

row_count: usize

Total rows written

expanded: bool

Whether we’re in expanded mode

Implementations

impl<'w> StreamingTableFormatter<'w>

pub fn new( columns: Vec<CqlColumn>, colorizer: &'w CqlColorizer, writer: &'w mut dyn Write, page_size: usize, ) -> Self

Create a new streaming formatter in tabular mode.

pub fn new_expanded( columns: Vec<CqlColumn>, colorizer: &'w CqlColorizer, writer: &'w mut dyn Write, ) -> Self

Create a new streaming formatter in expanded mode.

pub fn add_row(&mut self, row: CqlRow) -> Result<()>

Add a row to the formatter. Returns Err if writing fails (e.g. broken pipe).

pub fn flush_writer(&mut self) -> Result<()>

pub fn finish(self) -> Result<usize>

Finish the stream: flush any buffered rows and write the footer. Returns the total row count.

fn flush_first_page(&mut self) -> Result<()>

Compute column widths from the first page buffer and flush everything.

fn write_separator(&mut self) -> Result<()>

fn write_header_row(&mut self) -> Result<()>

fn write_row(&mut self, row: &CqlRow) -> Result<()>

fn write_expanded_row(&mut self, row: &CqlRow) -> Result<()>