Module blocking 

Bridges a blocking source — a Parquet artifact, a compressed archive — into a bounded, back-pressured Stream, off the async runtime’s workers.

Constants

DEFAULT_BLOCKING_CHUNK_SIZE

Chunk size stream_blocking_iter is documented for, and a sensible default for a decoder feeding a backtest.

Functions

stream_blocking_iter

Bridge a blocking, fallible iterator into a bounded Stream, decoding on Tokio’s blocking pool.