ObservableQueueDrain

All Known Implementing Classes:

ObservableBufferExactBoundary.BufferExactBoundaryObserver, ObservableBufferTimed.BufferExactBoundedObserver, ObservableBufferTimed.BufferExactUnboundedObserver, ObservableBufferTimed.BufferSkipBoundedObserver, QueueDrainObserver
```
public interface ObservableQueueDrain<T,U>
```

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	Description
`void`	`accept(Observer<? 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.

- Method Detail
  - cancelled
```
boolean cancelled()
```
  - done
```
boolean done()
```
  - error
```
java.lang.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
```
void accept(Observer<? super U> a,
            T v)
```
    Accept the value and return true if forwarded.
    
    Parameters:
    
    a - the subscriber to deliver values to
    
    v - the value to deliver