Class BooleanSubscription
java.lang.Object
java.util.concurrent.atomic.AtomicBoolean
io.reactivex.rxjava3.internal.subscriptions.BooleanSubscription
- All Implemented Interfaces:
Serializable
,org.reactivestreams.Subscription
public final class BooleanSubscription
extends AtomicBoolean
implements org.reactivestreams.Subscription
Subscription implementation that ignores request but remembers the cancellation
which can be checked via isCancelled.
- See Also:
-
Field Summary
Fields -
Constructor Summary
Constructors -
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, weakCompareAndSet, weakCompareAndSetAcquire, weakCompareAndSetPlain, weakCompareAndSetRelease, weakCompareAndSetVolatile
-
Field Details
-
serialVersionUID
private static final long serialVersionUID- See Also:
-
-
Constructor Details
-
BooleanSubscription
public BooleanSubscription()
-
-
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
-
isCancelled
public boolean isCancelled()Returns true if this BooleanSubscription has been cancelled.- Returns:
- true if this BooleanSubscription has been cancelled
-
toString
- Overrides:
toString
in classAtomicBoolean
-