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
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description int
getSegment()
Returns the segment for all keys in the publisher.void
subscribe(org.reactivestreams.Subscriber<? super Type> s)
static <Type> SegmentPublisherWrapper<Type>
wrap(io.reactivex.rxjava3.flowables.GroupedFlowable<Integer,? extends Type> groupedFlowable)
-
-
-
Method Detail
-
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.
-
-