Module chunker 

Structs

StrictBatchSizeStream

Given a stream of record batches, this will yield batches of a fixed size.

Functions

break_stream

chunk_concat_stream

chunk_stream