reactor.core.publisher

类 InnerStressSubscriber<T>

java.lang.Object

reactor.core.publisher.StressSubscriber<T>

reactor.core.publisher.InnerStressSubscriber<T>

所有已实现的接口:

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

public class InnerStressSubscriber<T>
extends StressSubscriber<T>

字段概要

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

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

方法概要

限定符和类型	方法和说明
void	cancel()
void	onComplete()

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

currentContext, onError, onNext, onSubscribe, request

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

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

方法详细资料

onComplete

public void onComplete()

指定者:

onComplete 在接口中 org.reactivestreams.Subscriber<T>

覆盖:

onComplete 在类中 StressSubscriber<T>

cancel

public void cancel()

覆盖:

cancel 在类中 StressSubscriber<T>