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
FieldsModifier and TypeFieldDescription(package private) Notification
<T> (package private) final Semaphore
(package private) final AtomicReference
<Notification<T>> -
Constructor Summary
Constructors -
Method Summary
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 Details
-
notify
-
value
-
iteratorNotification
Notification<T> iteratorNotification
-
-
Constructor Details
-
LatestSubscriberIterator
LatestSubscriberIterator()
-
-
Method Details
-
onNext
- Specified by:
onNext
in interfaceorg.reactivestreams.Subscriber<T>
-
onError
- Specified by:
onError
in interfaceorg.reactivestreams.Subscriber<T>
-
onComplete
public void onComplete()- Specified by:
onComplete
in interfaceorg.reactivestreams.Subscriber<T>
-
hasNext
public boolean hasNext() -
next
-
remove
public void remove()
-