T
- the source type to which this subscriber will be subscribedU
- the value type in the queueV
- the value type the child subscriber acceptspublic abstract class QueueDrainSubscriber<T,U,V> extends Object implements FlowableSubscriber<T>, QueueDrain<U,V>
Modifier and Type | Field and Description |
---|---|
protected org.reactivestreams.Subscriber<? super V> |
actual |
protected boolean |
cancelled |
protected boolean |
done |
protected Throwable |
error |
protected SimplePlainQueue<U> |
queue |
Constructor and Description |
---|
QueueDrainSubscriber(org.reactivestreams.Subscriber<? super V> actual,
SimplePlainQueue<U> queue) |
Modifier and Type | Method and Description |
---|---|
boolean |
accept(org.reactivestreams.Subscriber<? super V> a,
U v)
Accept the value and return true if forwarded.
|
boolean |
cancelled() |
boolean |
done() |
boolean |
enter() |
Throwable |
error() |
boolean |
fastEnter() |
protected void |
fastPathEmitMax(U value,
boolean delayError,
Disposable dispose) |
protected void |
fastPathOrderedEmitMax(U value,
boolean delayError,
Disposable dispose) |
int |
leave(int m)
Adds m to the wip counter.
|
long |
produced(long n) |
long |
requested() |
void |
requested(long n) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
onSubscribe
protected final org.reactivestreams.Subscriber<? super V> actual
protected final SimplePlainQueue<U> queue
protected volatile boolean cancelled
protected volatile boolean done
protected Throwable error
public QueueDrainSubscriber(org.reactivestreams.Subscriber<? super V> actual, SimplePlainQueue<U> queue)
public final boolean cancelled()
cancelled
in interface QueueDrain<U,V>
public final boolean done()
done
in interface QueueDrain<U,V>
public final boolean enter()
enter
in interface QueueDrain<U,V>
public final boolean fastEnter()
protected final void fastPathEmitMax(U value, boolean delayError, Disposable dispose)
protected final void fastPathOrderedEmitMax(U value, boolean delayError, Disposable dispose)
public boolean accept(org.reactivestreams.Subscriber<? super V> a, U v)
QueueDrain
accept
in interface QueueDrain<U,V>
a
- the subscriberv
- the valuepublic final Throwable error()
error
in interface QueueDrain<U,V>
public final int leave(int m)
QueueDrain
leave
in interface QueueDrain<U,V>
m
- the value to addpublic final long requested()
requested
in interface QueueDrain<U,V>
public final long produced(long n)
produced
in interface QueueDrain<U,V>
public final void requested(long n)
Copyright © 2018 JBoss by Red Hat. All rights reserved.