public interface QueueDrain<T,U>
Modifier and Type | Method and Description |
---|---|
boolean |
accept(org.reactivestreams.Subscriber<? super U> a,
T v)
Accept the value and return true if forwarded.
|
boolean |
cancelled() |
boolean |
done() |
boolean |
enter() |
Throwable |
error() |
int |
leave(int m)
Adds m to the wip counter.
|
long |
produced(long n) |
long |
requested() |
boolean cancelled()
boolean done()
Throwable error()
boolean enter()
long requested()
long produced(long n)
int leave(int m)
m
- the value to addCopyright © 2018 JBoss by Red Hat. All rights reserved.