Uses of Interface
io.reactivex.rxjava3.internal.util.QueueDrain
-
Packages that use QueueDrain Package Description io.reactivex.rxjava3.internal.operators.flowable io.reactivex.rxjava3.internal.subscribers io.reactivex.rxjava3.internal.util -
-
Uses of QueueDrain in io.reactivex.rxjava3.internal.operators.flowable
Classes in io.reactivex.rxjava3.internal.operators.flowable that implement QueueDrain Modifier and Type Class Description (package private) static class
FlowableBufferExactBoundary.BufferExactBoundarySubscriber<T,U extends java.util.Collection<? super T>,B>
(package private) static class
FlowableBufferTimed.BufferExactBoundedSubscriber<T,U extends java.util.Collection<? super T>>
(package private) static class
FlowableBufferTimed.BufferExactUnboundedSubscriber<T,U extends java.util.Collection<? super T>>
(package private) static class
FlowableBufferTimed.BufferSkipBoundedSubscriber<T,U extends java.util.Collection<? super T>>
-
Uses of QueueDrain in io.reactivex.rxjava3.internal.subscribers
Classes in io.reactivex.rxjava3.internal.subscribers that implement QueueDrain Modifier and Type Class Description class
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 QueueDrain Modifier and Type Method Description static <T,U>
booleanQueueDrainHelper. checkTerminated(boolean d, boolean empty, org.reactivestreams.Subscriber<?> s, boolean delayError, SimpleQueue<?> q, QueueDrain<T,U> qd)
static <T,U>
voidQueueDrainHelper. 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.
-