Class BlockingOperatorMostRecent.MostRecentObserver<T>

    • Constructor Detail

      • MostRecentObserver

        MostRecentObserver​(T value)
    • Method Detail

      • onError

        public void onError​(java.lang.Throwable e)
        Description copied from interface: Observer
        Notifies the Observer that the Observable has experienced an error condition.

        If the Observable calls this method, it will not thereafter call Observer.onNext(T) or Observer.onCompleted().

        Parameters:
        e - the exception encountered by the Observable
      • getIterable

        public java.util.Iterator<T> getIterable()
        The Iterator return is not thread safe. In other words don't call Iterator.hasNext() in one thread expect Iterator.next() called from a different thread to work.
        Returns:
        the Iterator instance