Uses of Record Class
io.fluxzero.common.tracking.MessageStoreBatch

Packages that use MessageStoreBatch

Package	Description
io.fluxzero.common.tracking

Uses of MessageStoreBatch in io.fluxzero.common.tracking

Methods in io.fluxzero.common.tracking that return MessageStoreBatch

Modifier and Type	Method	Description
static MessageStoreBatch	MessageStoreBatch.scan(Iterable<SerializedMessage> source, int maxSize, long maxBytes, Predicate<? super SerializedMessage> filter)	Scans source messages until the source count or accepted-message byte budget is exhausted.
protected MessageStoreBatch	DefaultTrackingStrategy.scanBatch(int[] segment, Position position, int batchSize, long maxBytes, Predicate<? super SerializedMessage> filter)
default MessageStoreBatch	MessageStore.scanBatch(Long minIndex, int maxSize, boolean inclusive, long maxBytes, Predicate<? super SerializedMessage> filter)	Scans messages starting from the given minIndex, returning messages accepted by filter and metadata about the unfiltered source scan.