Interface ObservableQueueDrain<T,U>
- All Known Implementing Classes:
ObservableBufferExactBoundary.BufferExactBoundaryObserver
,ObservableBufferTimed.BufferExactBoundedObserver
,ObservableBufferTimed.BufferExactUnboundedObserver
,ObservableBufferTimed.BufferSkipBoundedObserver
,QueueDrainObserver
public interface ObservableQueueDrain<T,U>
-
Method Summary
-
Method Details
-
cancelled
boolean cancelled() -
done
boolean done() -
error
Throwable error() -
enter
boolean enter() -
leave
int leave(int m) Adds m to the wip counter.- Parameters:
m
- the value to add- Returns:
- the wip value after adding the value
-
accept
Accept the value and return true if forwarded.- Parameters:
a
- the subscriber to deliver values tov
- the value to deliver
-