Class BlockingObservableLatest<T>

  • Type Parameters:
    T - the value type
    All Implemented Interfaces:
    java.lang.Iterable<T>

    public final class BlockingObservableLatest<T>
    extends java.lang.Object
    implements java.lang.Iterable<T>
    Wait for and iterate over the latest values of the source observable. If the source works faster than the iterator, values may be skipped, but not the onError or onComplete events.
    • Constructor Detail

      • BlockingObservableLatest

        public BlockingObservableLatest​(ObservableSource<T> source)
    • Method Detail

      • iterator

        public java.util.Iterator<T> iterator()
        Specified by:
        iterator in interface java.lang.Iterable<T>