Interface NonBlockingStore.SegmentedPublisher<Type>

  • Type Parameters:
    Type - type of values in this Publisher.
    All Superinterfaces:
    org.reactivestreams.Publisher<Type>
    All Known Implementing Classes:
    SegmentPublisherWrapper, SingleSegmentPublisher
    Enclosing interface:
    NonBlockingStore<K,​V>

    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 Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      int getSegment()
      Returns the segment for all keys in the publisher.
      • Methods inherited from interface org.reactivestreams.Publisher

        subscribe
    • Method Detail

      • getSegment

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