Interface ChunkedDeserializingMessage.ChunkReader

Enclosing class:
ChunkedDeserializingMessage
Functional Interface:
This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
@FunctionalInterface public static interface ChunkedDeserializingMessage.ChunkReader
Reads serialized messages from a bounded index range while recovering chunked messages.

  • Method Summary

    Modifier and Type
    Method
    Description
    List<SerializedMessage>
    readRange(long minIndexInclusive, long maxIndexExclusive, int maxSize)
    Reads a page of messages from the given index range.

  • Method Details

    • readRange

      List<SerializedMessage> readRange(long minIndexInclusive, long maxIndexExclusive, int maxSize)
      Reads a page of messages from the given index range.
      Parameters:
      minIndexInclusive - the starting index (inclusive)
      maxIndexExclusive - the maximum index (exclusive)
      maxSize - the maximum number of messages to retrieve
      Returns:
      messages in the requested range, ordered by index