Interface QueueDrain<T,U>
-
- All Known Implementing Classes:
FlowableBufferExactBoundary.BufferExactBoundarySubscriber
,FlowableBufferTimed.BufferExactBoundedSubscriber
,FlowableBufferTimed.BufferExactUnboundedSubscriber
,FlowableBufferTimed.BufferSkipBoundedSubscriber
,QueueDrainSubscriber
public interface QueueDrain<T,U>
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method 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()
java.lang.Throwable
error()
int
leave(int m)
Adds m to the wip counter.long
produced(long n)
long
requested()
-
-
-
Method Detail
-
cancelled
boolean cancelled()
-
done
boolean done()
-
error
java.lang.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
-
-