T
- the value typepublic interface ConditionalSubscriber<T> extends FlowableSubscriber<T>
tryOnNext(Object)
method that
tells the caller the specified value has been accepted or
not.
This allows certain queue-drain or source-drain operators to avoid requesting 1 on behalf of a dropped value.
Modifier and Type | Method and Description |
---|---|
boolean |
tryOnNext(T t)
Conditionally takes the value.
|
onSubscribe
boolean tryOnNext(T t)
t
- the value to deliverCopyright © 2019. All rights reserved.