hu.akarnokd.rxjava2.internal.subscriptions

Class BooleanSubscription

java.lang.Object

java.util.concurrent.atomic.AtomicBoolean

hu.akarnokd.rxjava2.internal.subscriptions.BooleanSubscription

All Implemented Interfaces:

java.io.Serializable, org.reactivestreams.Subscription

public final class BooleanSubscription
extends java.util.concurrent.atomic.AtomicBoolean
implements org.reactivestreams.Subscription

Subscription implementation that ignores request but remembers the cancellation which can be checked via isCancelled.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
BooleanSubscription()

Method Summary

Modifier and Type	Method and Description
void	cancel()
boolean	isCancelled() Returns true if this BooleanSubscription has been cancelled.
void	request(long n)

Methods inherited from class java.util.concurrent.atomic.AtomicBoolean

compareAndSet, get, getAndSet, lazySet, set, toString, weakCompareAndSet

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

BooleanSubscription

public BooleanSubscription()

Method Detail

request

public void request(long n)

Specified by:

request in interface org.reactivestreams.Subscription

cancel

public void cancel()

Specified by:

cancel in interface org.reactivestreams.Subscription

isCancelled

public boolean isCancelled()

Returns true if this BooleanSubscription has been cancelled.

Returns:

true if this BooleanSubscription has been cancelled