Package org.infinispan.stream.impl
Class CompletionRehashPublisherDecorator<S>
- java.lang.Object
-
- org.infinispan.stream.impl.AbstractRehashPublisherDecorator<S>
-
- org.infinispan.stream.impl.CompletionRehashPublisherDecorator<S>
-
public class CompletionRehashPublisherDecorator<S> extends AbstractRehashPublisherDecorator<S>
PublisherDecorator that only notifies a user listener of segment completion after the last entry for a given segment has been retrieved from iteration.- Since:
- 9.0
- Author:
- wburns
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
complete()
org.reactivestreams.Publisher<S>
decorateLocal(ConsistentHash beginningCh, boolean onlyLocal, org.infinispan.commons.util.IntSet segmentsToFilter, org.reactivestreams.Publisher<S> localPublisher)
org.reactivestreams.Publisher<S>
decorateRemote(ClusterStreamManager.RemoteIteratorPublisher<S> remotePublisher)
void
valueIterated(Object obj)
-
-
-
Method Detail
-
valueIterated
public void valueIterated(Object obj)
-
complete
public void complete()
-
decorateRemote
public org.reactivestreams.Publisher<S> decorateRemote(ClusterStreamManager.RemoteIteratorPublisher<S> remotePublisher)
-
decorateLocal
public org.reactivestreams.Publisher<S> decorateLocal(ConsistentHash beginningCh, boolean onlyLocal, org.infinispan.commons.util.IntSet segmentsToFilter, org.reactivestreams.Publisher<S> localPublisher)
-
-