Uses of Interface
io.reactivex.rxjava3.internal.util.ObservableQueueDrain
-
Packages that use ObservableQueueDrain Package Description io.reactivex.rxjava3.internal.observers io.reactivex.rxjava3.internal.operators.observable io.reactivex.rxjava3.internal.util -
-
Uses of ObservableQueueDrain in io.reactivex.rxjava3.internal.observers
Classes in io.reactivex.rxjava3.internal.observers that implement ObservableQueueDrain Modifier and Type Class Description class
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 ObservableQueueDrain Modifier and Type Class Description (package private) static class
ObservableBufferExactBoundary.BufferExactBoundaryObserver<T,U extends java.util.Collection<? super T>,B>
(package private) static class
ObservableBufferTimed.BufferExactBoundedObserver<T,U extends java.util.Collection<? super T>>
(package private) static class
ObservableBufferTimed.BufferExactUnboundedObserver<T,U extends java.util.Collection<? super T>>
(package private) static class
ObservableBufferTimed.BufferSkipBoundedObserver<T,U extends java.util.Collection<? super T>>
-
Uses of ObservableQueueDrain in io.reactivex.rxjava3.internal.util
Methods in io.reactivex.rxjava3.internal.util with parameters of type ObservableQueueDrain Modifier and Type Method Description static <T,U>
booleanQueueDrainHelper. checkTerminated(boolean d, boolean empty, Observer<?> observer, boolean delayError, SimpleQueue<?> q, Disposable disposable, ObservableQueueDrain<T,U> qd)
static <T,U>
voidQueueDrainHelper. drainLoop(SimplePlainQueue<T> q, Observer<? super U> a, boolean delayError, Disposable dispose, ObservableQueueDrain<T,U> qd)
-