hu.akarnokd.rxjava2.internal.disposables

Class MultipleAssignmentResource<T>

java.lang.Object

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

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

Type Parameters:

T - the resource type

All Implemented Interfaces:

Disposable, java.io.Serializable

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

Holds onto resources with a custom disposer callback and replacing a resource doesn't call the disposer but only when the MultipleAssignmentResource is disposed.

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
MultipleAssignmentResource(Consumer<? super T> disposer) Constructor with a custom disposer callback.
MultipleAssignmentResource(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.
void	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

MultipleAssignmentResource

public MultipleAssignmentResource(Consumer<? super T> disposer)

Constructor with a custom disposer callback.

Parameters:

disposer -

MultipleAssignmentResource

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

Constructor with a custom disposer callback and the initial resource

Parameters:

disposer -

initialResource -

Method Detail

setResource

public void 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

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

dispose

public void dispose()

Description copied from interface: Disposable

Dispose the resource, the operation should be idempotent.

Specified by:

dispose in interface Disposable

isDisposed

public boolean isDisposed()

Returns true if this resource has been disposed.

Returns:

true if this resource has been disposed