Uses of Interface
io.reactivex.rxjava3.internal.util.ObservableQueueDrain
Packages that use ObservableQueueDrain
Package
Description
-
Uses of ObservableQueueDrain in io.reactivex.rxjava3.internal.observers
Classes in io.reactivex.rxjava3.internal.observers that implement ObservableQueueDrainModifier and TypeClassDescriptionclass
QueueDrainObserver<T,
U, V> Abstract base class for subscribers that hold another subscriber, a queue and requires queue-drain behavior. -
Uses of ObservableQueueDrain in io.reactivex.rxjava3.internal.operators.observable
Classes in io.reactivex.rxjava3.internal.operators.observable that implement ObservableQueueDrainModifier and TypeClassDescription(package private) static final class
ObservableBufferExactBoundary.BufferExactBoundaryObserver<T,
U extends Collection<? super T>, B> (package private) static final class
ObservableBufferTimed.BufferExactBoundedObserver<T,
U extends Collection<? super T>> (package private) static final class
ObservableBufferTimed.BufferExactUnboundedObserver<T,
U extends Collection<? super T>> (package private) static final class
ObservableBufferTimed.BufferSkipBoundedObserver<T,
U extends Collection<? super T>> -
Uses of ObservableQueueDrain in io.reactivex.rxjava3.internal.util
Methods in io.reactivex.rxjava3.internal.util with parameters of type ObservableQueueDrainModifier and TypeMethodDescriptionstatic <T,
U> boolean QueueDrainHelper.checkTerminated
(boolean d, boolean empty, Observer<?> observer, boolean delayError, SimpleQueue<?> q, Disposable disposable, ObservableQueueDrain<T, U> qd) static <T,
U> void QueueDrainHelper.drainLoop
(SimplePlainQueue<T> q, Observer<? super U> a, boolean delayError, Disposable dispose, ObservableQueueDrain<T, U> qd)