Module multistream_batch::multi_buf_batch

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

MultiBufBatch

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.

Stats

Usage statistics.

Enums

PollResult

Represents result from MultiBufBatch.poll() function call.