Package | Description |
---|---|
io.reactivex.internal.observers | |
io.reactivex.internal.queue | |
io.reactivex.internal.subscribers | |
io.reactivex.internal.util |
Modifier and Type | Field and Description |
---|---|
protected SimplePlainQueue<U> |
QueueDrainObserver.queue |
Constructor and Description |
---|
QueueDrainObserver(Observer<? super V> actual,
SimplePlainQueue<U> queue) |
Modifier and Type | Class and Description |
---|---|
class |
MpscLinkedQueue<T>
A multi-producer single consumer unbounded queue.
|
class |
SpscArrayQueue<E>
A Single-Producer-Single-Consumer queue backed by a pre-allocated buffer.
|
class |
SpscLinkedArrayQueue<T>
A single-producer single-consumer array-backed queue which can allocate new arrays in case the consumer is slower
than the producer.
|
Modifier and Type | Field and Description |
---|---|
protected SimplePlainQueue<U> |
QueueDrainSubscriber.queue |
Constructor and Description |
---|
QueueDrainSubscriber(org.reactivestreams.Subscriber<? super V> actual,
SimplePlainQueue<U> queue) |
Modifier and Type | Method and Description |
---|---|
static <T,U> void |
QueueDrainHelper.drainLoop(SimplePlainQueue<T> q,
Observer<? super U> a,
boolean delayError,
Disposable dispose,
ObservableQueueDrain<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.
|
Copyright © 2019. All rights reserved.