T - the value typepublic final class ScalarSubscription<T>
extends java.util.concurrent.atomic.AtomicBoolean
implements org.reactivestreams.Subscription
| Constructor and Description |
|---|
ScalarSubscription(org.reactivestreams.Subscriber<? super T> subscriber,
T value) |
| Modifier and Type | Method and Description |
|---|---|
void |
cancel() |
void |
request(long n) |