Uses of Class
io.fluxzero.sdk.common.serialization.ChunkedDeserializingMessage

Packages that use ChunkedDeserializingMessage

Package	Description
io.fluxzero.sdk.common.serialization
io.fluxzero.sdk.tracking

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

Methods in io.fluxzero.sdk.common.serialization that return types with arguments of type ChunkedDeserializingMessage

Modifier and Type	Method	Description
static Optional<ChunkedDeserializingMessage>	ChunkedDeserializingMessage.recoverFromContinuation(io.fluxzero.common.api.SerializedMessage continuation, io.fluxzero.common.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.

Uses of ChunkedDeserializingMessage in io.fluxzero.sdk.tracking

Method parameters in io.fluxzero.sdk.tracking with type arguments of type ChunkedDeserializingMessage

Modifier and Type	Method	Description
protected List<DeserializingMessage>	DefaultTracking.deserializeMessageList(List<io.fluxzero.common.api.SerializedMessage> serializedMessages, String topic, TrackingClient trackingClient, Map<String, ChunkedDeserializingMessage> activeChunkedMessages, int recoveryMaxFetchSize)
protected Stream<DeserializingMessage>	DefaultTracking.deserializeMessages(List<io.fluxzero.common.api.SerializedMessage> serializedMessages, String topic, TrackingClient trackingClient, Map<String, ChunkedDeserializingMessage> activeChunkedMessages, int recoveryMaxFetchSize)