Uses of Interface
io.fluxzero.sdk.common.serialization.ChunkedDeserializingMessage.ChunkReader

Packages that use ChunkedDeserializingMessage.ChunkReader

Package	Description
io.fluxzero.sdk.common.serialization

Uses of ChunkedDeserializingMessage.ChunkReader in io.fluxzero.sdk.common.serialization

Methods in io.fluxzero.sdk.common.serialization with parameters of type ChunkedDeserializingMessage.ChunkReader

Modifier and Type	Method	Description
static Optional<ChunkedDeserializingMessage>	ChunkedDeserializingMessage.recoverFromContinuation(SerializedMessage continuation, MessageType messageType, String topic, Serializer serializer, long minIndexInclusive, int pageSize, ChunkedDeserializingMessage.ChunkReader chunkReader)	Reconstructs a chunked message when tracking observes a continuation after the original first chunk was already read by an earlier tracker run.