Class SegmentPublisherWrapper<Type>
java.lang.Object
org.infinispan.persistence.support.SegmentPublisherWrapper<Type>
- All Implemented Interfaces:
NonBlockingStore.SegmentedPublisher<Type>
,org.reactivestreams.Publisher<Type>
public class SegmentPublisherWrapper<Type>
extends Object
implements NonBlockingStore.SegmentedPublisher<Type>
-
Method Summary
Modifier and TypeMethodDescriptionint
Returns the segment for all keys in the publisher.void
static <Type> SegmentPublisherWrapper
<Type>
-
Method Details
-
wrap
public static <Type> SegmentPublisherWrapper<Type> wrap(io.reactivex.rxjava3.flowables.GroupedFlowable<Integer, ? extends Type> groupedFlowable) -
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<Type>
- Returns:
- segment the data the publisher provides maps to.
-
subscribe
- Specified by:
subscribe
in interfaceorg.reactivestreams.Publisher<Type>
-