Package reactor.core

Interface Fuseable.ConditionalSubscriber<T>

Type Parameters:

T - the value type

All Superinterfaces:

CoreSubscriber<T>, Subscriber<T>

Enclosing interface:

Fuseable

public static interface Fuseable.ConditionalSubscriber<T>
extends CoreSubscriber<T>

A subscriber variant that can immediately tell if it consumed the value or not, directly allowing a new value to be sent if it didn't. This avoids the usual request(1) round-trip for dropped values.

Method Summary

Modifier and Type	Method	Description
boolean	tryOnNext(T t)	Try consuming the value and return true if successful.

Methods inherited from interface reactor.core.CoreSubscriber

currentContext, onSubscribe

Methods inherited from interface org.reactivestreams.Subscriber

onComplete, onError, onNext

Method Details

tryOnNext

boolean tryOnNext(T t)

Try consuming the value and return true if successful.

Parameters:

t - the value to consume, not null

Returns:

true if consumed, false if dropped and a new value can be immediately sent