QueueDrain

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
  - accept
```
boolean accept(org.reactivestreams.Subscriber<? super U> a,
               T v)
```
    Accept the value and return true if forwarded.
    
    Parameters:
    
    a - the subscriber
    
    v - the value
    
    Returns:
    
    true if the value was delivered