public static interface BackpressureDrainManager.BackpressureQueueCallback
Modifier and Type | Method and Description |
---|---|
boolean |
accept(Object value)
Override this method to deliver an element to downstream.
|
void |
complete(Throwable exception)
Override this method to deliver a normal or exceptional
terminal event.
|
Object |
peek()
Override this method to peek for the next element,
null meaning no next element available now.
|
Object |
poll()
Override this method to poll (consume) the next element,
null meaning no next element available now.
|
Object peek()
It will be called plain and while holding this object's monitor.
Object poll()
boolean accept(Object value)
value
- the value to deliver, not nullvoid complete(Throwable exception)
exception
- if not null, contains the terminal exceptionCopyright © 2018. All rights reserved.