Uses of Interface
io.fluxzero.sdk.common.serialization.ChunkedDeserializingMessage.ChunkReader
Packages that use ChunkedDeserializingMessage.ChunkReader
-
Uses of ChunkedDeserializingMessage.ChunkReader in io.fluxzero.sdk.common.serialization
Methods in io.fluxzero.sdk.common.serialization with parameters of type ChunkedDeserializingMessage.ChunkReaderModifier and TypeMethodDescriptionstatic 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.