BlockingFlowableLatest.LatestSubscriberIterator

java.lang.Object
- io.reactivex.rxjava3.subscribers.DisposableSubscriber<Notification<T>>
- - io.reactivex.rxjava3.internal.operators.flowable.BlockingFlowableLatest.LatestSubscriberIterator<T>

All Implemented Interfaces:

FlowableSubscriber<Notification<T>>, Disposable, java.util.Iterator<T>, org.reactivestreams.Subscriber<Notification<T>>

Enclosing class:

BlockingFlowableLatest<T>
```
static final class BlockingFlowableLatest.LatestSubscriberIterator<T>
extends DisposableSubscriber<Notification<T>>
implements java.util.Iterator<T>
```
Subscriber of source, iterator for output.

Field Summary

Fields
Modifier and Type	Field	Description
`(package private) Notification<T>`	`iteratorNotification`
`(package private) java.util.concurrent.Semaphore`	`notify`
`(package private) java.util.concurrent.atomic.AtomicReference<Notification<T>>`	`value`

Constructor Summary

Constructors
Constructor Description

LatestSubscriberIterator()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`boolean`	`hasNext()`
`T`	`next()`
`void`	`onComplete()`
`void`	`onError(java.lang.Throwable e)`
`void`	`onNext(Notification<T> args)`
`void`	`remove()`

Methods inherited from class io.reactivex.rxjava3.subscribers.DisposableSubscriber
cancel, dispose, isDisposed, onStart, onSubscribe, request

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.Iterator
forEachRemaining

- Field Detail
  - notify
```
final java.util.concurrent.Semaphore notify
```
  - value
```
final java.util.concurrent.atomic.AtomicReference<Notification<T>> value
```
  - iteratorNotification
```
Notification<T> iteratorNotification
```
- Constructor Detail
  - LatestSubscriberIterator
```
LatestSubscriberIterator()
```
- Method Detail
  - onNext
```
public void onNext(Notification<T> args)
```
    Specified by:
    
    onNext in interface org.reactivestreams.Subscriber<T>
  - onError
```
public void onError(java.lang.Throwable e)
```
    Specified by:
    
    onError in interface org.reactivestreams.Subscriber<T>
  - onComplete
```
public void onComplete()
```
    Specified by:
    
    onComplete in interface org.reactivestreams.Subscriber<T>
  - hasNext
```
public boolean hasNext()
```
    Specified by:
    
    hasNext in interface java.util.Iterator<T>
  - next
```
public T next()
```
    Specified by:
    
    next in interface java.util.Iterator<T>
  - remove
```
public void remove()
```
    Specified by:
    
    remove in interface java.util.Iterator<T>