hu.akarnokd.rxjava2.internal.disposables

Class ArrayCompositeResource<T>

java.lang.Object

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

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

Type Parameters:

T - the resource tpye

All Implemented Interfaces:

Disposable, java.io.Serializable

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

A composite resource with a fixed number of slots.

Note that since the implementation leaks the methods of AtomicReferenceArray, one must be careful to only call setResource, replaceResource 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
ArrayCompositeResource(int capacity, Consumer<? super T> disposer)

Method Summary

Modifier and Type	Method and Description
void	dispose() Dispose the resource, the operation should be idempotent.
boolean	isDisposed()
T	replaceResource(int index, T resource) Replaces the resource at the specified index and returns the old resource.
boolean	setResource(int index, T resource) Sets the resource at the specified index and disposes the old resource.

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

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

Methods inherited from class java.lang.Object

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

Constructor Detail

ArrayCompositeResource

public ArrayCompositeResource(int capacity,
                              Consumer<? super T> disposer)

Method Detail

setResource

public boolean setResource(int index,
                           T resource)

Sets the resource at the specified index and disposes the old resource.

Parameters:

index -

resource -

Returns:

true if the resource has ben set, false if the composite has been disposed

replaceResource

public T replaceResource(int index,
                         T resource)

Replaces the resource at the specified index and returns the old resource.

Parameters:

index -

resource -

Returns:

the old resource, can be null

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()