Struct BlockReader 

pub struct BlockReader<'io, I: Io + ?Sized> { /* private fields */ }

Reads consecutive Native Block values from an Io implementation.

Reader retains buffered bytes between calls to read.

Implementations

impl<'io, I: Io + ?Sized> BlockReader<'io, I>

pub fn new( io: Pin<&'io mut I>, alloc: Allocator, opts: BlockOpts, ) -> Result<Self>

Creates a reader using framing described by opts.

Use BlockOpts::default for output from clickhouse local.

pub fn read(&mut self) -> Result<Option<Block>>

Decodes next block. Returns None for EOF at a block boundary.

Trait Implementations

impl<I: Io + ?Sized> Drop for BlockReader<'_, I>

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.