Commons/cz.acrobits.commons.tasks/ObservableFuture

ObservableFuture

interface ObservableFuture<T> : Future<T>

Inheritors

ObservableFutureTask

Types

Emitter

interface Emitter<T>

Functions

cancel

abstract fun cancel(p: Boolean): Boolean

canceled

@NonNull

@Contract(value = " -> new")

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

create

@NonNull

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

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

done

@NonNull

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

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

exceptionNow

open fun exceptionNow(): Throwable

flatMap

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

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

fromListenableFuture

@NonNull

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

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

@NonNull

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

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

get

abstract fun get(): V

isCancelled

abstract fun isCancelled(): Boolean

isDone

abstract fun isDone(): Boolean

resultNow

open fun resultNow(): V

state

open fun state(): Future.State

whenCanceled

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

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

whenDone

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

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