Top Description Methods
io.reactivex.internal.fuseable

public Interface ConditionalSubscriber<T>

extends FlowableSubscriber<T>
Known Direct Implementers
io.reactivex.internal.operators.flowable.FlowableSkipUntil.SkipUntilMainSubscriber, io.reactivex.internal.operators.flowable.FlowableDistinctUntilChanged.DistinctUntilChangedSubscriber, io.reactivex.internal.operators.flowable.FlowableDoFinally.DoFinallyConditionalSubscriber, io.reactivex.internal.operators.flowable.FlowableFilter.FilterSubscriber, io.reactivex.internal.operators.flowable.FlowableWithLatestFrom.WithLatestFromSubscriber, io.reactivex.internal.operators.flowable.FlowableWithLatestFromMany.WithLatestFromSubscriber, io.reactivex.internal.operators.parallel.ParallelDoOnNextTry.ParallelDoOnNextSubscriber, io.reactivex.internal.operators.parallel.ParallelDoOnNextTry.ParallelDoOnNextConditionalSubscriber, io.reactivex.internal.operators.parallel.ParallelFilter.BaseFilterSubscriber, io.reactivex.internal.operators.parallel.ParallelFilterTry.BaseFilterSubscriber, io.reactivex.internal.operators.parallel.ParallelMap.ParallelMapConditionalSubscriber, io.reactivex.internal.operators.parallel.ParallelMapTry.ParallelMapTrySubscriber, io.reactivex.internal.operators.parallel.ParallelMapTry.ParallelMapTryConditionalSubscriber, io.reactivex.internal.subscribers.BasicFuseableConditionalSubscriber
Type Parameters
<T>
the value type
Imports
io.reactivex.FlowableSubscriber

A Subscriber with an additional 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.

Method Summary

Modifier and TypeMethod and Description
public boolean

Returns:

true if the value has been accepted, false if the value has been rejected and the next value can be sent immediately
tryOnNext
(T
the value to deliver
t
)

Conditionally takes the value.

Inherited from io.reactivex.FlowableSubscriber:
onSubscribe

Method Detail

tryOnNextback to summary
public boolean tryOnNext(T t)

Conditionally takes the value.

Parameters
t:T

the value to deliver

Returns:boolean

true if the value has been accepted, false if the value has been rejected and the next value can be sent immediately