hu.akarnokd.rxjava2.internal.subscriptions

Class DisposableSubscription

java.lang.Object

java.util.concurrent.atomic.AtomicReference<Disposable>

hu.akarnokd.rxjava2.internal.subscriptions.DisposableSubscription

All Implemented Interfaces:

java.io.Serializable, org.reactivestreams.Subscription

public final class DisposableSubscription
extends java.util.concurrent.atomic.AtomicReference<Disposable>
implements org.reactivestreams.Subscription

Subscription that ignores (but validates) requests and delegates cancel to a disposable instance.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
DisposableSubscription() Constructs an empty DisposableSubscription.
DisposableSubscription(Disposable d) Constructs a DisposableSubscription by wrapping the given Disposable.

Method Summary

Modifier and Type	Method and Description
void	cancel()
boolean	replaceDisposable(Disposable d) Replaces any existing disposable with a new disposable but doesn't dispose the old one.
void	request(long n)
boolean	setDisposable(Disposable d) Sets a new disposable resource and disposes any old one.

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

accumulateAndGet, compareAndSet, get, getAndAccumulate, getAndSet, getAndUpdate, lazySet, set, toString, updateAndGet, weakCompareAndSet

Methods inherited from class java.lang.Object

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

Constructor Detail

DisposableSubscription

public DisposableSubscription()

Constructs an empty DisposableSubscription.

DisposableSubscription

public DisposableSubscription(Disposable d)

Constructs a DisposableSubscription by wrapping the given Disposable.

Parameters:

d - the disposable to wrap, may be null

Method Detail

request

public void request(long n)

Specified by:

request in interface org.reactivestreams.Subscription

setDisposable

public boolean setDisposable(Disposable d)

Sets a new disposable resource and disposes any old one.

Parameters:

d - the new disposable to set

Returns:

false if this Subscription has been cancelled

replaceDisposable

public boolean replaceDisposable(Disposable d)

Replaces any existing disposable with a new disposable but doesn't dispose the old one.

Parameters:

d - the new disposable to set

Returns:

false if this disposable was disposed

cancel

public void cancel()

Specified by:

cancel in interface org.reactivestreams.Subscription