Commons/cz.acrobits.commons.tasks/ObservableFutureTask

ObservableFutureTask

class ObservableFutureTask<T> : FutureTask<T> , ObservableFuture<T>

Constructors

ObservableFutureTask

constructor(callable: Callable<T>)

Functions

open fun cancel(mayInterruptIfRunning: Boolean): Boolean

@Contract(value = " -> new")

open fun <T> canceled(): ObservableFuture<T>

@Contract(value = "_ -> new")

open fun <T> create(@NonNull emitter: Consumer<ObservableFuture.Emitter<T>>): ObservableFuture<T>

@Contract(value = "_ -> new")

open fun <T> done(value: T): ObservableFuture<T>

open fun exceptionNow(): Throwable

@Contract(value = "_ -> new")

open fun flatMap(future: (T) -> ObservableFuture<T>): ObservableFuture<T>

@Contract(value = "_, _ -> new")

open fun flatMap(future: (T) -> ObservableFuture<T>, executor: Executor): ObservableFuture<T>

fromListenableFuture

@Contract(value = "_ -> new")

open fun <T> fromListenableFuture(listenableFuture: ListenableFuture<T>): ObservableFuture<T>

@Contract(value = "_, _ -> new")

open fun <T> fromListenableFuture(listenableFuture: ListenableFuture<T>, executor: Executor): ObservableFuture<T>

open fun get(): V

open fun isCancelled(): Boolean

open fun isDone(): Boolean

open fun resultNow(): V

open fun run()

open fun state(): Future.State

open fun toString(): String

open fun whenCanceled(callback: Runnable): ObservableFuture<T>

open fun whenCanceled(callback: Runnable, executor: Executor): ObservableFuture<T>

open fun whenDone(callback: Consumer<T>): ObservableFuture<T>

open fun whenDone(callback: Consumer<T>, executor: Executor): ObservableFuture<T>