Package org.infinispan.persistence.spi

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

    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 Details

    • getSegment

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