Interface ISubscriptionIntermediateFuture<E>

    • Method Detail

      • addQuietListener

        void addQuietListener​(IResultListener<java.util.Collection<E>> listener)
        Add a listener which does not consume the initial results. I.e. even if it is the first listener to be added to this future, a second listener will still receive the initial results.
      • getIntermediateResults

        java.util.Collection<E> getIntermediateResults()
        Get the intermediate results that are available. Note: The semantics of this method is different to the normal intermediate future due to the fire-and-forget-semantics!
        Specified by:
        getIntermediateResults in interface IIntermediateFuture<E>