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 TypeMethodDescriptionint
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.
-