Interface QueueDrain<T,U>
- All Known Implementing Classes:
FlowableBufferExactBoundary.BufferExactBoundarySubscriber
,FlowableBufferTimed.BufferExactBoundedSubscriber
,FlowableBufferTimed.BufferExactUnboundedSubscriber
,FlowableBufferTimed.BufferSkipBoundedSubscriber
,QueueDrainSubscriber
public interface QueueDrain<T,U>
-
Method Details
-
cancelled
boolean cancelled() -
done
boolean done() -
error
Throwable error() -
enter
boolean enter() -
requested
long requested() -
produced
long produced(long n) -
leave
int leave(int m) Adds m to the wip counter.- Parameters:
m
- the value to add- Returns:
- the current value after adding m
-
accept
Accept the value and return true if forwarded.- Parameters:
a
- the subscriberv
- the value- Returns:
- true if the value was delivered
-