Class SingleSegmentPublisher<E>
java.lang.Object
org.infinispan.persistence.support.SingleSegmentPublisher<E>
- All Implemented Interfaces:
NonBlockingStore.SegmentedPublisher<E>
,org.reactivestreams.Publisher<E>
public class SingleSegmentPublisher<E>
extends Object
implements NonBlockingStore.SegmentedPublisher<E>
-
Method Summary
Modifier and TypeMethodDescriptionint
Returns the segment for all keys in the publisher.static <E> NonBlockingStore.SegmentedPublisher
<E> singleSegment
(int segment, org.reactivestreams.Publisher<? extends E> publisher) static <E> NonBlockingStore.SegmentedPublisher
<E> singleSegment
(org.reactivestreams.Publisher<? extends E> publisher) void
-
Method Details
-
singleSegment
public static <E> NonBlockingStore.SegmentedPublisher<E> singleSegment(int segment, org.reactivestreams.Publisher<? extends E> publisher) -
singleSegment
public static <E> NonBlockingStore.SegmentedPublisher<E> singleSegment(org.reactivestreams.Publisher<? extends E> publisher) -
getSegment
public int getSegment()Description copied from interface:NonBlockingStore.SegmentedPublisher
Returns the segment for all keys in the publisher.- Specified by:
getSegment
in interfaceNonBlockingStore.SegmentedPublisher<E>
- Returns:
- segment the data the publisher provides maps to.
-
subscribe
- Specified by:
subscribe
in interfaceorg.reactivestreams.Publisher<E>
-