Struct TokenStream 

pub struct TokenStream<'a> { /* private fields */ }

Reads a reassembled response message one token at a time.

The stream is stateful because rows carry no types of their own: they are decoded against the COLMETADATA that preceded them.

Implementations

impl<'a> TokenStream<'a>

pub fn new(bytes: &'a [u8]) -> Self

pub fn columns(&self) -> &Arc<Vec<Column>>

The columns of the result set currently being read.

pub fn next_token(&mut self) -> Result<Option<Token>>

The next token, or None at the end of the message.

Not an Iterator: a token can fail to parse, and a stream that hides that behind None would silently truncate a result set.