Uses of Interface
io.reactivex.rxjava3.internal.util.QueueDrain
Packages that use QueueDrain
Package
Description
-
Uses of QueueDrain in io.reactivex.rxjava3.internal.operators.flowable
Classes in io.reactivex.rxjava3.internal.operators.flowable that implement QueueDrainModifier and TypeClassDescription(package private) static final class
FlowableBufferExactBoundary.BufferExactBoundarySubscriber<T,
U extends Collection<? super T>, B> (package private) static final class
FlowableBufferTimed.BufferExactBoundedSubscriber<T,
U extends Collection<? super T>> (package private) static final class
FlowableBufferTimed.BufferExactUnboundedSubscriber<T,
U extends Collection<? super T>> (package private) static final class
FlowableBufferTimed.BufferSkipBoundedSubscriber<T,
U extends Collection<? super T>> -
Uses of QueueDrain in io.reactivex.rxjava3.internal.subscribers
Classes in io.reactivex.rxjava3.internal.subscribers that implement QueueDrainModifier and TypeClassDescriptionclass
QueueDrainSubscriber<T,
U, V> Abstract base class for subscribers that hold another subscriber, a queue and requires queue-drain behavior. -
Uses of QueueDrain in io.reactivex.rxjava3.internal.util
Methods in io.reactivex.rxjava3.internal.util with parameters of type QueueDrainModifier and TypeMethodDescriptionstatic <T,
U> boolean QueueDrainHelper.checkTerminated
(boolean d, boolean empty, org.reactivestreams.Subscriber<?> s, boolean delayError, SimpleQueue<?> q, QueueDrain<T, U> qd) static <T,
U> void QueueDrainHelper.drainMaxLoop
(SimplePlainQueue<T> q, org.reactivestreams.Subscriber<? super U> a, boolean delayError, Disposable dispose, QueueDrain<T, U> qd) Drain the queue but give up with an error if there aren't enough requests.