Class FlowableConcatMap.SimpleScalarSubscription<T>
java.lang.Object
java.util.concurrent.atomic.AtomicBoolean
io.reactivex.rxjava3.internal.operators.flowable.FlowableConcatMap.SimpleScalarSubscription<T>
- All Implemented Interfaces:
Serializable
,org.reactivestreams.Subscription
- Enclosing class:
FlowableConcatMap<T,
R>
static final class FlowableConcatMap.SimpleScalarSubscription<T>
extends AtomicBoolean
implements org.reactivestreams.Subscription
-
Field Summary
Fields -
Constructor Summary
ConstructorsConstructorDescriptionSimpleScalarSubscription
(T value, org.reactivestreams.Subscriber<? super T> downstream) -
Method Summary
Methods inherited from class java.util.concurrent.atomic.AtomicBoolean
compareAndExchange, compareAndExchangeAcquire, compareAndExchangeRelease, compareAndSet, get, getAcquire, getAndSet, getOpaque, getPlain, lazySet, set, setOpaque, setPlain, setRelease, toString, weakCompareAndSet, weakCompareAndSetAcquire, weakCompareAndSetPlain, weakCompareAndSetRelease, weakCompareAndSetVolatile
-
Field Details
-
serialVersionUID
private static final long serialVersionUID- See Also:
-
downstream
-
value
-
-
Constructor Details
-
SimpleScalarSubscription
-
-
Method Details
-
request
public void request(long n) - Specified by:
request
in interfaceorg.reactivestreams.Subscription
-
cancel
public void cancel()- Specified by:
cancel
in interfaceorg.reactivestreams.Subscription
-