hu.akarnokd.rxjava2.internal.disposables

Class SerialResource<T>

java.lang.Object

java.util.concurrent.atomic.AtomicReference<java.lang.Object>

hu.akarnokd.rxjava2.internal.disposables.SerialResource<T>

Type Parameters:

T - the resource type

All Implemented Interfaces:

Disposable, java.io.Serializable

public final class SerialResource<T>
extends java.util.concurrent.atomic.AtomicReference<java.lang.Object>
implements Disposable

Holds onto resources with a custom disposer callback and replacing a resource calls the disposer with the old value.

This resource container disposable helps in avoiding the wrapping of other resources into Disposables.

Note that since the implementation leaks the methods of AtomicReference, one must be careful to only call setResource and dispose on it. All other methods may lead to undefined behavior and should be used by internal means only.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
SerialResource(Consumer<? super T> disposer) Constructor with a custom disposer callback.
SerialResource(Consumer<? super T> disposer, T initialResource) Constructor with a custom disposer callback and the initial resource

Method Summary

Modifier and Type	Method and Description
void	dispose() Dispose the resource, the operation should be idempotent.
T	getResource() Returns the current held resource or null if no resource is set or the container has been disposed.
boolean	isDisposed() Returns true if this resource has been disposed.
boolean	setResource(T newResource) Atomically replaces the current resource with the new resource but doesn't call the disposer for it.

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

SerialResource

public SerialResource(Consumer<? super T> disposer)

Constructor with a custom disposer callback.

Parameters:

disposer -

SerialResource

public SerialResource(Consumer<? super T> disposer,
                      T initialResource)

Constructor with a custom disposer callback and the initial resource

Parameters:

disposer -

initialResource -

Method Detail

setResource

public boolean setResource(T newResource)

Atomically replaces the current resource with the new resource but doesn't call the disposer for it.

Parameters:

newResource - the new resource to replace the old one

Returns:

true if the set succeeded, false if the container is disposed

dispose

public void dispose()

Description copied from interface: Disposable

Dispose the resource, the operation should be idempotent.

Specified by:

dispose in interface Disposable

getResource

public T getResource()

Returns the current held resource or null if no resource is set or the container has been disposed.

Returns:

the currently held resource

isDisposed

public boolean isDisposed()

Returns true if this resource has been disposed.

Returns:

true if this resource has been disposed