Class 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 Detail

      • valueIterated

        public void valueIterated​(Object obj)
      • complete

        public void complete()
      • decorateLocal

        public org.reactivestreams.Publisher<S> decorateLocal​(ConsistentHash beginningCh,
                                                              boolean onlyLocal,
                                                              org.infinispan.commons.util.IntSet segmentsToFilter,
                                                              org.reactivestreams.Publisher<S> localPublisher)