io.reactivex.disposables

Class Disposables

java.lang.Object

io.reactivex.disposables.Disposables

public final class Disposables
extends java.lang.Object

Utility class to help create disposables by wrapping other types.

Since:

2.0

Method Summary

Methods

Modifier and Type	Method and Description
static Disposable	disposed() Returns a disposed Disposable instance.
static Disposable	empty() Returns a new, non-disposed Disposable instance.
static Disposable	from(Action run) Construct a Disposable by wrapping a Action that is executed exactly once when the Disposable is disposed.
static Disposable	from(java.util.concurrent.Future<?> future) Construct a Disposable by wrapping a Future that is cancelled exactly once when the Disposable is disposed.
static Disposable	from(java.util.concurrent.Future<?> future, boolean allowInterrupt) Construct a Disposable by wrapping a Runnable that is executed exactly once when the Disposable is disposed.
static Disposable	from(java.lang.Runnable run) Construct a Disposable by wrapping a Runnable that is executed exactly once when the Disposable is disposed.
static Disposable	from(org.reactivestreams.Subscription subscription) Construct a Disposable by wrapping a Subscription that is cancelled exactly once when the Disposable is disposed.

Methods inherited from class java.lang.Object

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

Method Detail

from

public static Disposable from(java.lang.Runnable run)

Construct a Disposable by wrapping a Runnable that is executed exactly once when the Disposable is disposed.

Parameters:

run - the Runnable to wrap

Returns:

the new Disposable instance

from

public static Disposable from(Action run)

Construct a Disposable by wrapping a Action that is executed exactly once when the Disposable is disposed.

Parameters:

run - the Action to wrap

Returns:

the new Disposable instance

from

public static Disposable from(java.util.concurrent.Future<?> future)

Construct a Disposable by wrapping a Future that is cancelled exactly once when the Disposable is disposed.

Parameters:

future - the Future to wrap

Returns:

the new Disposable instance

from

public static Disposable from(java.util.concurrent.Future<?> future,
              boolean allowInterrupt)

Construct a Disposable by wrapping a Runnable that is executed exactly once when the Disposable is disposed.

Parameters:

future - the Runnable to wrap

allowInterrupt - if true, the future cancel happens via Future.cancel(true)

Returns:

the new Disposable instance

from

public static Disposable from(org.reactivestreams.Subscription subscription)

Construct a Disposable by wrapping a Subscription that is cancelled exactly once when the Disposable is disposed.

Parameters:

subscription - the Runnable to wrap

Returns:

the new Disposable instance

empty

public static Disposable empty()

Returns a new, non-disposed Disposable instance.

Returns:

a new, non-disposed Disposable instance

disposed

public static Disposable disposed()

Returns a disposed Disposable instance.

Returns:

a disposed Disposable instance