T
- the value typepublic interface ConditionalSubscriber<T> extends FlowableSubscriber<T>
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 © 2018 JBoss by Red Hat. All rights reserved.