Struct BlockReader 

pub struct BlockReader { /* private fields */ }

Reader for blocks from network

Implementations

impl BlockReader

pub fn new(server_revision: u64) -> Self

Create a new block reader

pub fn with_compression(self, method: CompressionMethod) -> Self

Enable compression

pub async fn read_block(&self, conn: &mut Connection) -> Result<Block>

Read a block from the connection.

For compressed connections, ClickHouse may split a single logical block across multiple compressed frames (each frame ≤ max_compress_block_size, typically 1 MB). This method reads frames until the accumulated decompressed data forms a complete block.

Note: Caller is responsible for skipping temp table name if needed (matches C++ ReadBlock / CompressedInput).