Module multistream_batch::buf_batch

This module provides BufBatch that will buffer items until 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 first item was appended to the batch.

Enums

PollResult

Represents result from poll function call.