T - the value typepublic interface ConditionalSubscriber<T>
extends org.reactivestreams.Subscriber<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 |
onNextIf(T t)
Conditionally takes the value.
|
boolean onNextIf(T t)
t - the value to deliver