Additional top-level classes in compilation unit: QueueDrainSubscriberPad0, QueueDrainSubscriberWip, QueueDrainSubscriberPad2.
| Modifier and Type | Field and Description |
|---|---|
| protected volatile boolean | |
| protected volatile boolean | |
| protected final Observer | |
| protected Throwable | |
| protected final SimplePlainQueue |
| Access | Constructor and Description |
|---|---|
| public |
| Modifier and Type | Method and Description |
|---|---|
| public void | accept(Observer<? super V>
the subscriber to deliver values to a, U the value to deliver v)Implements io. |
| public final boolean | |
| public final boolean | |
| public final boolean | |
| public final Throwable | |
| protected final void | |
| protected final void | fastPathOrderedEmit(U
the value to emit or queue up value, boolean if true, errors are delayed until the source has terminated delayError, Disposable the resource to dispose if the drain terminates disposable)Makes sure the fast-path emits in order. |
| public final int | leave(int
the value to add m)Implements io. |
| cancelled | back to summary |
|---|---|
| protected volatile boolean cancelled | |
| done | back to summary |
|---|---|
| protected volatile boolean done | |
| downstream | back to summary |
|---|---|
| protected final Observer<? super V> downstream | |
| error | back to summary |
|---|---|
| protected Throwable error | |
| queue | back to summary |
|---|---|
| protected final SimplePlainQueue<U> queue | |
| QueueDrainObserver | back to summary |
|---|---|
| public QueueDrainObserver(Observer<? super V> actual, SimplePlainQueue<U> queue) | |
| accept | back to summary |
|---|---|
| public void accept(Observer<? super V> a, U v) Implements io. Doc from io. Accept the value and return true if forwarded. | |
| cancelled | back to summary |
|---|---|
| public final boolean cancelled() Implements io.
| |
| done | back to summary |
|---|---|
| public final boolean done() Implements io.
| |
| enter | back to summary |
|---|---|
| public final boolean enter() Implements io.
| |
| error | back to summary |
|---|---|
| public final Throwable error() Implements io.
| |
| fastPathEmit | back to summary |
|---|---|
| protected final void fastPathEmit(U value, boolean delayError, Disposable dispose) | |
| fastPathOrderedEmit | back to summary |
|---|---|
| protected final void fastPathOrderedEmit(U value, boolean delayError, Disposable disposable) Makes sure the fast-path emits in order.
| |
| leave | back to summary |
|---|---|
| public final int leave(int m) Implements io. Doc from io. Adds m to the wip counter.
| |