Class BlockingFlowableLatest<T>

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

    public final class BlockingFlowableLatest<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.
    • Field Summary

      Fields 
      Modifier and Type Field Description
      (package private) org.reactivestreams.Publisher<? extends T> source  
    • Constructor Summary

      Constructors 
      Constructor Description
      BlockingFlowableLatest​(org.reactivestreams.Publisher<? extends T> source)  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      java.util.Iterator<T> iterator()  
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
      • Methods inherited from interface java.lang.Iterable

        forEach, spliterator
    • Field Detail

      • source

        final org.reactivestreams.Publisher<? extends T> source
    • Constructor Detail

      • BlockingFlowableLatest

        public BlockingFlowableLatest​(org.reactivestreams.Publisher<? extends T> source)
    • Method Detail

      • iterator

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