Class BlockingFlowableMostRecent.MostRecentSubscriber<T>
java.lang.Object
io.reactivex.rxjava3.subscribers.DefaultSubscriber<T>
io.reactivex.rxjava3.internal.operators.flowable.BlockingFlowableMostRecent.MostRecentSubscriber<T>
- All Implemented Interfaces:
FlowableSubscriber<T>
,org.reactivestreams.Subscriber<T>
- Enclosing class:
BlockingFlowableMostRecent<T>
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescription(package private) final class
-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionTheBlockingFlowableMostRecent.MostRecentSubscriber<T>.Iterator
return is not thread safe.void
void
void
Methods inherited from class io.reactivex.rxjava3.subscribers.DefaultSubscriber
cancel, onStart, onSubscribe, request
-
Field Details
-
value
-
-
Constructor Details
-
MostRecentSubscriber
MostRecentSubscriber(T value)
-
-
Method Details
-
onComplete
public void onComplete() -
onError
-
onNext
-
getIterable
TheBlockingFlowableMostRecent.MostRecentSubscriber<T>.Iterator
return is not thread safe. In other words don't callBlockingFlowableMostRecent.MostRecentSubscriber.Iterator.hasNext()
in one thread expectBlockingFlowableMostRecent.MostRecentSubscriber.Iterator.next()
called from a different thread to work.- Returns:
- the Iterator
-