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>