Package | Description |
---|---|
io.reactivex.internal.subscribers | |
io.reactivex.internal.util |
Modifier and Type | Class and Description |
---|---|
class |
QueueDrainSubscriber<T,U,V>
Abstract base class for subscribers that hold another subscriber, a queue
and requires queue-drain behavior.
|
Modifier and Type | Method and Description |
---|---|
static <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.
|
Copyright © 2018 JBoss by Red Hat. All rights reserved.