reactor.core.publisher

类 ConditionalStressSubscriber<T>

java.lang.Object

reactor.core.publisher.StressSubscriber<T>

reactor.core.publisher.ConditionalStressSubscriber<T>

所有已实现的接口:

org.reactivestreams.Subscriber<T>, CoreSubscriber<T>, Fuseable.ConditionalSubscriber<T>

public class ConditionalStressSubscriber<T>
extends StressSubscriber<T>
implements Fuseable.ConditionalSubscriber<T>

字段概要

从类继承的字段 reactor.core.publisher.StressSubscriber

concurrentOnComplete, concurrentOnError, concurrentOnNext, concurrentOnSubscribe, discardedValues, droppedErrors, error, guard, onCompleteCalls, onErrorCalls, onNextCalls, onNextDiscarded, onSubscribeCalls, receivedValues, stacktraceOnComplete, stacktraceOnError, stacktraceOnNext, stacktraceOnSubscribe

构造器概要

构造器

构造器和说明
ConditionalStressSubscriber() Build a ConditionalStressSubscriber that makes an unbounded request upon subscription.
ConditionalStressSubscriber(long initRequest) Build a ConditionalStressSubscriber that requests the provided amount in StressSubscriber.onSubscribe(Subscription).
ConditionalStressSubscriber(long initRequest, java.util.function.Predicate<T> tryOnNextPredicate) Build a ConditionalStressSubscriber that requests the provided amount in StressSubscriber.onSubscribe(Subscription).
ConditionalStressSubscriber(java.util.function.Predicate<T> tryOnNextPredicate) Build a ConditionalStressSubscriber that that makes an unbounded request upon subscription.

方法概要

限定符和类型	方法和说明
boolean	tryOnNext(T value) Try consuming the value and return true if successful.

从类继承的方法 reactor.core.publisher.StressSubscriber

cancel, currentContext, onComplete, onError, onNext, onSubscribe, request

从类继承的方法 java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

从接口继承的方法 reactor.core.CoreSubscriber

currentContext, onSubscribe

从接口继承的方法 org.reactivestreams.Subscriber

onComplete, onError, onNext

构造器详细资料

ConditionalStressSubscriber

public ConditionalStressSubscriber()

Build a ConditionalStressSubscriber that makes an unbounded request upon subscription.

ConditionalStressSubscriber

public ConditionalStressSubscriber(java.util.function.Predicate<T> tryOnNextPredicate)

Build a ConditionalStressSubscriber that that makes an unbounded request upon subscription.

参数:

tryOnNextPredicate - the tryOnNext predicate

ConditionalStressSubscriber

public ConditionalStressSubscriber(long initRequest)

Build a ConditionalStressSubscriber that requests the provided amount in StressSubscriber.onSubscribe(Subscription). Use 0 to avoid any initial request upon subscription.

参数:

initRequest - the requested amount upon subscription, or zero to disable initial request

ConditionalStressSubscriber

public ConditionalStressSubscriber(long initRequest,
                                   java.util.function.Predicate<T> tryOnNextPredicate)

Build a ConditionalStressSubscriber that requests the provided amount in StressSubscriber.onSubscribe(Subscription). Use 0 to avoid any initial request upon subscription.

参数:

initRequest - the requested amount upon subscription, or zero to disable initial request

tryOnNextPredicate - the tryOnNext predicate

方法详细资料

tryOnNext

public boolean tryOnNext(T value)

从接口复制的说明: Fuseable.ConditionalSubscriber

Try consuming the value and return true if successful.

指定者:

tryOnNext 在接口中 Fuseable.ConditionalSubscriber<T>

参数:

value - the value to consume, not null

返回:

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