Package com.github.tonivade.purefun.concurrent

Interface Promise<T>

All Superinterfaces:

Applicable<Promise<?>,T>, Bindable<Promise<?>,T>, Kind<Promise<?>,T>, Mappable<Promise<?>,T>, PromiseOf<T>

All Known Implementing Classes:

PromiseImpl

public sealed interface Promise<T>
extends PromiseOf<T>, Bindable<Promise<?>,T>, Applicable<Promise<?>,T>
permits PromiseImpl<T>

Nested Class Summary

Nested classes/interfaces inherited from interface com.github.tonivade.purefun.core.Applicable

Applicable.Map2<F extends Applicable<F,?>,A,B>, Applicable.Map3<F extends Applicable<F,?>,A,B,C>, Applicable.Map4<F extends Applicable<F,?>,A,B,C,D>, Applicable.Map5<F extends Applicable<F,?>,A,B,C,D,E>

Method Summary

Modifier and Type	Method	Description
default <R> Promise<R>	andThen(Kind<Promise<?>,? extends R> next)
<R> Promise<R>	ap(Kind<Promise<?>,? extends Function1<? super T,? extends R>> apply)
Try<T>	await()
Try<T>	await(Duration timeout)
default Promise<T>	cancel()
default Promise<T>	complete(Try<? extends T> value)
default Promise<T>	failed(Throwable error)
<R> Promise<R>	flatMap(Function1<? super T,? extends Kind<Promise<?>,? extends R>> mapper)
static <T> Promise<T>	from(CompletableFuture<? extends T> future)
static <T> Promise<T>	from(Executor executor, CompletableFuture<? extends T> future)
boolean	isCompleted()
static <T> Promise<T>	make()
static <T> Promise<T>	make(Executor executor)
<R> Promise<R>	map(Function1<? super T,? extends R> mapper)
static <A, B, C, D, E, R> Promise<R>	mapN(Promise<? extends A> fa, Promise<? extends B> fb, Promise<? extends C> fc, Promise<? extends D> fd, Promise<? extends E> fe, Function5<? super A,? super B,? super C,? super D,? super E,? extends R> mapper)
static <A, B, C, D, E> Promise<E>	mapN(Promise<? extends A> fa, Promise<? extends B> fb, Promise<? extends C> fc, Promise<? extends D> fd, Function4<? super A,? super B,? super C,? super D,? extends E> mapper)
static <A, B, C, D> Promise<D>	mapN(Promise<? extends A> fa, Promise<? extends B> fb, Promise<? extends C> fc, Function3<? super A,? super B,? super C,? extends D> mapper)
static <A, B, C> Promise<C>	mapN(Promise<? extends A> fa, Promise<? extends B> fb, Function2<? super A,? super B,? extends C> mapper)
Promise<T>	onComplete(Consumer1<? super Try<? extends T>> consumer)
default Promise<T>	onFailure(Consumer1<? super Throwable> consumer)
default Promise<T>	onSuccess(Consumer1<? super T> consumer)
default Promise<T>	succeeded(T value)
default Promise<Unit>	then(Consumer1<? super T> next)
default Promise<Unit>	thenRun(CheckedRunnable next)
boolean	tryComplete(Try<? extends T> value)

Methods inherited from interface com.github.tonivade.purefun.core.Applicable

zip, zipLeft, zipRight, zipWith

Methods inherited from interface com.github.tonivade.purefun.Kind

fix, kind

Method Details

tryComplete

boolean tryComplete(Try<? extends T> value)

cancel

default Promise<T> cancel()

complete

default Promise<T> complete(Try<? extends T> value)

succeeded

default Promise<T> succeeded(T value)

failed

default Promise<T> failed(Throwable error)

onComplete

Promise<T> onComplete(Consumer1<? super Try<? extends T>> consumer)

onSuccess

default Promise<T> onSuccess(Consumer1<? super T> consumer)

onFailure

default Promise<T> onFailure(Consumer1<? super Throwable> consumer)

map

<R> Promise<R> map(Function1<? super T,? extends R> mapper)

Specified by:

map in interface Applicable<Promise<?>,T>

Specified by:

map in interface Bindable<Promise<?>,T>

Specified by:

map in interface Mappable<Promise<?>,T>

ap

<R> Promise<R> ap(Kind<Promise<?>,? extends Function1<? super T,? extends R>> apply)

Specified by:

ap in interface Applicable<Promise<?>,T>

andThen

default <R> Promise<R> andThen(Kind<Promise<?>,? extends R> next)

Specified by:

andThen in interface Bindable<Promise<?>,T>

flatMap

<R> Promise<R> flatMap(Function1<? super T,? extends Kind<Promise<?>,? extends R>> mapper)

Specified by:

flatMap in interface Bindable<Promise<?>,T>

then

default Promise<Unit> then(Consumer1<? super T> next)

thenRun

default Promise<Unit> thenRun(CheckedRunnable next)

await

Try<T> await()

await

Try<T> await(Duration timeout)

isCompleted

boolean isCompleted()

make

static <T> Promise<T> make()

make

static <T> Promise<T> make(Executor executor)

from

static <T> Promise<T> from(CompletableFuture<? extends T> future)

from

static <T> Promise<T> from(Executor executor,
 CompletableFuture<? extends T> future)

mapN

static <A,
B,
C> Promise<C> mapN(Promise<? extends A> fa,
 Promise<? extends B> fb,
 Function2<? super A,? super B,? extends C> mapper)

mapN

static <A,
B,
C,
D> Promise<D> mapN(Promise<? extends A> fa,
 Promise<? extends B> fb,
 Promise<? extends C> fc,
 Function3<? super A,? super B,? super C,? extends D> mapper)

mapN

static <A,
B,
C,
D,
E> Promise<E> mapN(Promise<? extends A> fa,
 Promise<? extends B> fb,
 Promise<? extends C> fc,
 Promise<? extends D> fd,
 Function4<? super A,? super B,? super C,? super D,? extends E> mapper)

mapN

static <A,
B,
C,
D,
E,
R> Promise<R> mapN(Promise<? extends A> fa,
 Promise<? extends B> fb,
 Promise<? extends C> fc,
 Promise<? extends D> fd,
 Promise<? extends E> fe,
 Function5<? super A,? super B,? super C,? super D,? super E,? extends R> mapper)