Package org.infinispan.stream.impl
Class AbstractRehashPublisherDecorator<S>
- java.lang.Object
-
- org.infinispan.stream.impl.AbstractRehashPublisherDecorator<S>
-
- Direct Known Subclasses:
CompletionRehashPublisherDecorator
public abstract class AbstractRehashPublisherDecorator<S> extends Object
Abstract publisher decorator that is used to notify segment listener of loss of segments while entries are being retrieved.- Since:
- 9.0
- Author:
- wburns
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description org.reactivestreams.Publisher<S>
decorateLocal(ConsistentHash beginningCh, boolean onlyLocal, org.infinispan.commons.util.IntSet segmentsToFilter, org.reactivestreams.Publisher<S> localPublisher)
Invoked for a local publisher, which only completes segments if the consistent hash after completion is the same as the one providedorg.reactivestreams.Publisher<S>
decorateRemote(ClusterStreamManager.RemoteIteratorPublisher<S> remotePublisher)
Invoked for each remote publisher to provide additional functionality
-
-
-
Method Detail
-
decorateRemote
public abstract org.reactivestreams.Publisher<S> decorateRemote(ClusterStreamManager.RemoteIteratorPublisher<S> remotePublisher)
Invoked for each remote publisher to provide additional functionality- Parameters:
remotePublisher
- the provided remote publisher- Returns:
- the resulting publisher (usually wrapped in some way)
-
decorateLocal
public abstract org.reactivestreams.Publisher<S> decorateLocal(ConsistentHash beginningCh, boolean onlyLocal, org.infinispan.commons.util.IntSet segmentsToFilter, org.reactivestreams.Publisher<S> localPublisher)
Invoked for a local publisher, which only completes segments if the consistent hash after completion is the same as the one provided- Parameters:
beginningCh
- the consistent has to test againstonlyLocal
- whether this publisher is only done locally (that is there are no other remote publishers)segmentsToFilter
- the segments to use for this invocationlocalPublisher
- the internal local publisher- Returns:
- the resulting publisher (usually wrapped in some way)
-
-