Struct BatchConfig 

pub struct BatchConfig {
    pub max_items: usize,
    pub max_delay: Duration,
}

Controls automatic batching for stream and feed channels. Items are accumulated and flushed as a batch when either condition is met (whichever comes first):

• max_items items have accumulated
• max_delay has elapsed since the first item in the current batch

A batched list of items will be wrapped into a single WireEnvelope at the transport layer, sharing the same MessageId and headers. Byte-level concerns (frame size limits, throttling) are handled by the transport layer, not the batch writer.

Fields

max_items: usize

Maximum items per batch. When this many items accumulate, the batch is flushed immediately.

max_delay: Duration

Maximum time to wait for more items before flushing. If fewer than max_items are buffered but this duration elapses since the first item, the batch is flushed.

Implementations

impl BatchConfig

pub fn new(max_items: usize, max_delay: Duration) -> Self

Create a new batch configuration with the given limits.

Trait Implementations

impl Clone for BatchConfig

fn clone(&self) -> BatchConfig

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for BatchConfig

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for BatchConfig

fn default() -> Self

Returns the “default value” for a type.