StressSubscriber (reactor-3)

java.lang.Object
- reactor.core.publisher.StressSubscriber<T>

所有已实现的接口:

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

直接已知子类:

ConditionalStressSubscriber, InnerStressSubscriber
```
public class StressSubscriber<T>
extends java.lang.Object
implements CoreSubscriber<T>
```

字段概要

字段
限定符和类型	字段和说明
`java.util.concurrent.atomic.AtomicBoolean`	`concurrentOnComplete`
`java.util.concurrent.atomic.AtomicBoolean`	`concurrentOnError`
`java.util.concurrent.atomic.AtomicBoolean`	`concurrentOnNext`
`java.util.concurrent.atomic.AtomicBoolean`	`concurrentOnSubscribe`
`java.util.List<T>`	`discardedValues`
`java.util.List<java.lang.Throwable>`	`droppedErrors`
`java.lang.Throwable`	`error`
`java.util.concurrent.atomic.AtomicReference<java.lang.Throwable>`	`guard`
`java.util.concurrent.atomic.AtomicInteger`	`onCompleteCalls`
`java.util.concurrent.atomic.AtomicInteger`	`onErrorCalls`
`java.util.concurrent.atomic.AtomicInteger`	`onNextCalls`
`java.util.concurrent.atomic.AtomicInteger`	`onNextDiscarded`
`java.util.concurrent.atomic.AtomicInteger`	`onSubscribeCalls`
`java.util.List<T>`	`receivedValues`
`java.lang.Throwable`	`stacktraceOnComplete`
`java.lang.Throwable`	`stacktraceOnError`
`java.lang.Throwable`	`stacktraceOnNext`
`java.lang.Throwable`	`stacktraceOnSubscribe`

构造器概要

构造器
构造器和说明
`StressSubscriber()` Build a `StressSubscriber` that makes an unbounded request upon subscription.
`StressSubscriber(long initRequest)` Build a `StressSubscriber` that requests the provided amount in `onSubscribe(Subscription)`.

方法概要

所有方法实例方法具体方法
限定符和类型	方法和说明
`void`	`cancel()`
`Context`	`currentContext()` Request a `Context` from dependent components which can include downstream operators during subscribing or a terminal `Subscriber`.
`void`	`onComplete()`
`void`	`onError(java.lang.Throwable throwable)`
`void`	`onNext(T value)`
`void`	`onSubscribe(org.reactivestreams.Subscription subscription)` Implementors should initialize any state used by `Subscriber.onNext(Object)` before calling `Subscription.request(long)`.
`void`	`request(long n)`

从类继承的方法 java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- 字段详细资料
  - error
```
public java.lang.Throwable error
```
  - droppedErrors
```
public java.util.List<java.lang.Throwable> droppedErrors
```
  - guard
```
public java.util.concurrent.atomic.AtomicReference<java.lang.Throwable> guard
```
  - concurrentOnNext
```
public java.util.concurrent.atomic.AtomicBoolean concurrentOnNext
```
  - stacktraceOnNext
```
public java.lang.Throwable stacktraceOnNext
```
  - concurrentOnError
```
public java.util.concurrent.atomic.AtomicBoolean concurrentOnError
```
  - stacktraceOnError
```
public java.lang.Throwable stacktraceOnError
```
  - concurrentOnComplete
```
public java.util.concurrent.atomic.AtomicBoolean concurrentOnComplete
```
  - stacktraceOnComplete
```
public java.lang.Throwable stacktraceOnComplete
```
  - concurrentOnSubscribe
```
public java.util.concurrent.atomic.AtomicBoolean concurrentOnSubscribe
```
  - stacktraceOnSubscribe
```
public java.lang.Throwable stacktraceOnSubscribe
```
  - onNextCalls
```
public final java.util.concurrent.atomic.AtomicInteger onNextCalls
```
  - receivedValues
```
public final java.util.List<T> receivedValues
```
  - onNextDiscarded
```
public final java.util.concurrent.atomic.AtomicInteger onNextDiscarded
```
  - discardedValues
```
public final java.util.List<T> discardedValues
```
  - onErrorCalls
```
public final java.util.concurrent.atomic.AtomicInteger onErrorCalls
```
  - onCompleteCalls
```
public final java.util.concurrent.atomic.AtomicInteger onCompleteCalls
```
  - onSubscribeCalls
```
public final java.util.concurrent.atomic.AtomicInteger onSubscribeCalls
```
- 构造器详细资料
  - StressSubscriber
```
public StressSubscriber()
```
    Build a StressSubscriber that makes an unbounded request upon subscription.
  - StressSubscriber
```
public StressSubscriber(long initRequest)
```
    Build a StressSubscriber that requests the provided amount in onSubscribe(Subscription). Use 0 to avoid any initial request upon subscription.
    
    参数:
    
    initRequest - the requested amount upon subscription, or zero to disable initial request
- 方法详细资料
  - currentContext
```
public Context currentContext()
```
    从接口复制的说明: CoreSubscriber
    
    Request a Context from dependent components which can include downstream operators during subscribing or a terminal Subscriber.
    
    指定者:
    
    currentContext 在接口中 CoreSubscriber<T>
    
    返回:
    
    a resolved context or Context.empty()
  - onSubscribe
```
public void onSubscribe(org.reactivestreams.Subscription subscription)
```
    从接口复制的说明: CoreSubscriber
    
    Implementors should initialize any state used by Subscriber.onNext(Object) before calling Subscription.request(long). Should further onNext related state modification occur, thread-safety will be required.
    Note that an invalid request <= 0 will not produce an onError and will simply be ignored or reported through a debug-enabled Logger.
    
    指定者:
    
    onSubscribe 在接口中 org.reactivestreams.Subscriber<T>
    
    指定者:
    
    onSubscribe 在接口中 CoreSubscriber<T>
  - onNext
```
public void onNext(T value)
```
    指定者:
    
    onNext 在接口中 org.reactivestreams.Subscriber<T>
  - onError
```
public void onError(java.lang.Throwable throwable)
```
    指定者:
    
    onError 在接口中 org.reactivestreams.Subscriber<T>
  - onComplete
```
public void onComplete()
```
    指定者:
    
    onComplete 在接口中 org.reactivestreams.Subscriber<T>
  - request
```
public void request(long n)
```
  - cancel
```
public void cancel()
```

类 StressSubscriber<T>

字段概要

构造器概要

方法概要

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

字段详细资料

error

droppedErrors

guard

concurrentOnNext

stacktraceOnNext

concurrentOnError

stacktraceOnError

concurrentOnComplete

stacktraceOnComplete

concurrentOnSubscribe

stacktraceOnSubscribe

onNextCalls

receivedValues

onNextDiscarded

discardedValues

onErrorCalls

onCompleteCalls

onSubscribeCalls

构造器详细资料

StressSubscriber

StressSubscriber

方法详细资料

currentContext

onSubscribe

onNext

onError

onComplete

request

cancel