hu.akarnokd.rxjava2.internal.subscribers

Interface ConditionalSubscriber<T>

Type Parameters:

T - the value type

All Superinterfaces:

org.reactivestreams.Subscriber<T>

public interface ConditionalSubscriber<T>
extends org.reactivestreams.Subscriber<T>

An Subscriber with an additional onNextIf(T) 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.

Method Summary

Modifier and Type	Method and Description
boolean	onNextIf(T t) Conditionally takes the value.

Methods inherited from interface org.reactivestreams.Subscriber

onComplete, onError, onNext, onSubscribe

Method Detail

onNextIf

boolean onNextIf(T t)

Conditionally takes the value.

Parameters:

t - the value to deliver

Returns:

true if the value has been accepted, false if the value has been rejected