BlockingFlowableLatest

java.lang.Object
- io.reactivex.rxjava3.internal.operators.flowable.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.

- Nested Class Summary
  
  Nested Classes
  Modifier and Type Class Description
  
  (package private) static class BlockingFlowableLatest.LatestSubscriberIterator<T>
  Subscriber of source, iterator for output.
- 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>