Module multistream_batch::multi_buf_batch [−][src]
Expand description
This module provides MultiBufBatch
that will buffer items into multiple internal batches based on batch stream key until
one of the batches is ready. Then it provides accumulated items in one go along with the batch stream key using Drain
iterator.
Structs
Collects items into multiple batches based on stream key.
A batch may become ready after collecting max_size
number of items or until max_duration
has elapsed
since first item was appended to the batch.
Usage statistics.
Enums
Represents result from MultiBufBatch.poll()
function call.