Class BlockingFlowableLatest.LatestSubscriberIterator<T>

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, Iterator<T>, org.reactivestreams.Subscriber<Notification<T>>

Enclosing class:

BlockingFlowableLatest<T>

static final class BlockingFlowableLatest.LatestSubscriberIterator<T>
extends DisposableSubscriber<Notification<T>>
implements Iterator<T>

Subscriber of source, iterator for output.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) Notification<T>	iteratorNotification
(package private) final Semaphore	notify
(package private) final AtomicReference<Notification<T>>	value

Constructor Summary

Constructors

Constructor	Description
LatestSubscriberIterator()

Method Summary

Modifier and Type	Method	Description
boolean	hasNext()
T	next()
void	onComplete()
void	onError(Throwable e)
void	onNext(Notification<T> args)
void	remove()

Methods inherited from class DisposableSubscriber

cancel, dispose, isDisposed, onStart, onSubscribe, request

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface Iterator

forEachRemaining

Field Details

notify

final Semaphore notify

value

final AtomicReference<Notification<T>> value

iteratorNotification

Notification<T> iteratorNotification

Constructor Details

LatestSubscriberIterator

LatestSubscriberIterator()

Method Details

onNext

public void onNext(Notification<T> args)

Specified by:

onNext in interface org.reactivestreams.Subscriber<T>

onError

public void onError(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 Iterator<T>

next

public T next()

Specified by:

next in interface Iterator<T>

remove

public void remove()

Specified by:

remove in interface Iterator<T>