Class 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 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 against
        onlyLocal - whether this publisher is only done locally (that is there are no other remote publishers)
        segmentsToFilter - the segments to use for this invocation
        localPublisher - the internal local publisher
        Returns:
        the resulting publisher (usually wrapped in some way)