Module multistream_batch::buf_batch

This module provides BufBatch that will buffer items until the batch is ready and provide them in one go using Drain iterator.

Structs

BufBatch

Batches items in internal buffer up to max_size items or until max_duration has elapsed since the first item appended to the batch.

Enums

PollResult

Represents result from the poll function call.