CrdtMergeChangeStreamExtension extension

Helpers for grouping merge changes into stream payload batches.

on

• Stream<CrdtMergeChange>

Methods

chunked(int batchSize) → Stream<CrdtMergeSet>

Available on Stream<CrdtMergeChange>, provided by the CrdtMergeChangeStreamExtension extension

Emits lists with at most batchSize changes from this stream.