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>
static final class BlockingFlowableMostRecent.MostRecentSubscriber<T> extends DefaultSubscriber<T>
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description (package private) class
BlockingFlowableMostRecent.MostRecentSubscriber.Iterator
-
Field Summary
Fields Modifier and Type Field Description (package private) java.lang.Object
value
-
Constructor Summary
Constructors Constructor Description MostRecentSubscriber(T value)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description BlockingFlowableMostRecent.MostRecentSubscriber.Iterator
getIterable()
TheBlockingFlowableMostRecent.MostRecentSubscriber.Iterator
return is not thread safe.void
onComplete()
void
onError(java.lang.Throwable e)
void
onNext(T args)
-
Methods inherited from class io.reactivex.rxjava3.subscribers.DefaultSubscriber
cancel, onStart, onSubscribe, request
-
-
-
-
Constructor Detail
-
MostRecentSubscriber
MostRecentSubscriber(T value)
-
-
Method Detail
-
onComplete
public void onComplete()
-
onError
public void onError(java.lang.Throwable e)
-
onNext
public void onNext(T args)
-
getIterable
public BlockingFlowableMostRecent.MostRecentSubscriber.Iterator getIterable()
TheBlockingFlowableMostRecent.MostRecentSubscriber.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
-
-