async fn try_batch_barriers(
max_barrier_count_per_batch: u32,
input: &mut Peekable<BoxedMessageStream>,
) -> StreamResult<Option<MessageBatch>>Expand description
Tries to batch up to max_barrier_count_per_batch consecutive barriers within a single message batch.
Returns the message batch.
Returns None if end of stream.