Interface NonBlockingStore.SegmentedPublisher<Type>

  • Type Parameters:
    Type - type of values in this Publisher.
    All Superinterfaces:
    Enclosing interface:

    public static interface NonBlockingStore.SegmentedPublisher<Type>
    extends org.reactivestreams.Publisher<Type>
    A Publisher that provides a stream of values and the segments to which those values map.
    • Method Detail

      • getSegment

        int getSegment()
        Returns the segment for all keys in the publisher.
        segment the data the publisher provides maps to.