public interface ObservableQueueDrain<T,U>
Modifier and Type | Method and Description |
---|---|
void |
accept(Observer<? 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.
|
boolean cancelled()
boolean done()
Throwable error()
boolean enter()
int leave(int m)
m
- the value to addCopyright © 2019. All rights reserved.