SegmentPublisherWrapper (Infinispan JavaDoc 14.0.6.Final API)

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)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- 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 interface NonBlockingStore.SegmentedPublisher<Type>
    
    Returns:
    
    segment the data the publisher provides maps to.
  - subscribe
```
public void subscribe(org.reactivestreams.Subscriber<? super Type> s)
```
    Specified by:
    
    subscribe in interface org.reactivestreams.Publisher<Type>