Interface ObservableQueueDrain<T,U>
-
- 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.
-