Class BlockingFlowableLatest<T>

java.lang.Object
io.reactivex.rxjava3.internal.operators.flowable.BlockingFlowableLatest<T>
Type Parameters:
T - the value type emitted
All Implemented Interfaces:
Iterable<T>

public final class BlockingFlowableLatest<T> extends Object implements 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 Details

    • source

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

    • BlockingFlowableLatest

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