reactor.core.publisher

类 StressSubscription<T>

java.lang.Object

reactor.core.publisher.StressSubscription<T>

所有已实现的接口:

org.reactivestreams.Subscription

public class StressSubscription<T>
extends java.lang.Object
implements org.reactivestreams.Subscription

字段概要

字段

限定符和类型	字段和说明
java.util.concurrent.atomic.AtomicBoolean	cancelled
java.util.concurrent.atomic.AtomicInteger	requestsCount

构造器概要

构造器

构造器和说明
StressSubscription(CoreSubscriber<? super T> actual)

方法概要

限定符和类型	方法和说明
void	cancel()
void	request(long n)

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

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

字段详细资料

requestsCount

public final java.util.concurrent.atomic.AtomicInteger requestsCount

cancelled

public final java.util.concurrent.atomic.AtomicBoolean cancelled

构造器详细资料

StressSubscription

public StressSubscription(CoreSubscriber<? super T> actual)

方法详细资料

request

public void request(long n)

指定者:

request 在接口中 org.reactivestreams.Subscription

cancel

public void cancel()

指定者:

cancel 在接口中 org.reactivestreams.Subscription