reactor.core

Class Disposables

java.lang.Object

reactor.core.Disposables

public final class Disposables
extends Object

A support class that offers factory methods for implementations of the specialized Disposable sub-interfaces (Disposable.Composite, Disposable.Swap).

Author:

Simon Baslé, Stephane Maldini

Method Summary

Modifier and Type	Method and Description
static Disposable.Composite	composite() Create a new empty Disposable.Composite with atomic guarantees on all mutative operations.
static Disposable.Composite	composite(Disposable... disposables) Create and initialize a new Disposable.Composite with atomic guarantees on all mutative operations.
static Disposable.Composite	composite(Iterable<? extends Disposable> disposables) Create and initialize a new Disposable.Composite with atomic guarantees on all mutative operations.
static Disposable	disposed() Return a new Disposable that is already disposed.
static Disposable	never() Return a new Disposable that can never be disposed.
static Disposable	single() Return a new simple Disposable instance that is initially not disposed but can be by calling Disposable.dispose().
static Disposable.Swap	swap() Create a new empty Disposable.Swap with atomic guarantees on all mutative operations.

Methods inherited from class java.lang.Object

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

Method Detail

composite

public static Disposable.Composite composite()

Create a new empty Disposable.Composite with atomic guarantees on all mutative operations.

Returns:

an empty atomic Disposable.Composite

composite

public static Disposable.Composite composite(Disposable... disposables)

Create and initialize a new Disposable.Composite with atomic guarantees on all mutative operations.

Returns:

a pre-filled atomic Disposable.Composite

composite

public static Disposable.Composite composite(Iterable<? extends Disposable> disposables)

Create and initialize a new Disposable.Composite with atomic guarantees on all mutative operations.

Returns:

a pre-filled atomic Disposable.Composite

disposed

public static Disposable disposed()

Return a new Disposable that is already disposed.

Returns:

a new disposed Disposable.

never

public static Disposable never()

Return a new Disposable that can never be disposed. Calling Disposable.dispose() is a NO-OP and Disposable.isDisposed() always return false.

Returns:

a new Disposable that can never be disposed.

single

public static Disposable single()

Return a new simple Disposable instance that is initially not disposed but can be by calling Disposable.dispose().

Returns:

a new Disposable initially not yet disposed.

swap

public static Disposable.Swap swap()

Create a new empty Disposable.Swap with atomic guarantees on all mutative operations.

Returns:

an empty atomic Disposable.Swap