Module block_stream 

Block stream iterator with backpressure for large CAR/tensor exports.

Provides BlockStreamIterator for memory-efficient iteration over large block exports. Backpressure is applied synchronously: when the internal buffer is full, BlockStreamIterator::next_chunk returns None until the consumer calls BlockStreamIterator::drain_one.

Structs

BlockChunk

A single unit of work produced by BlockStreamIterator.

BlockStreamIterator

Synchronous, single-threaded streaming iterator over a block collection.

StreamConfig

Configuration for a BlockStreamIterator.

StreamStats

Cumulative statistics for a BlockStreamIterator.

Enums

BlockStreamState

Current state of a BlockStreamIterator.