Package com.github.tonivade.purefun.concurrent

Class FutureImpl<T>

java.lang.Object

com.github.tonivade.purefun.concurrent.FutureImpl<T>

All Implemented Interfaces:

Future<T>, FutureOf<T>, Bindable<Future<?>,T>, Mappable<Future<?>,T>, Kind<Future<?>,T>

final class FutureImpl<T>
extends Object
implements Future<T>

Field Summary

Fields

Modifier and Type	Field	Description
private final Cancellable	cancellable
private final Executor	executor
private final Promise<T>	promise
private final Propagate	propagate
private final UUID	uuid

Fields inherited from interface com.github.tonivade.purefun.concurrent.Future

DEFAULT_EXECUTOR

Constructor Summary

Constructors

Modifier	Constructor	Description
private	FutureImpl(Executor executor, Callback<T> callback)
private	FutureImpl(Executor executor, Callback<T> callback, Propagate propagate)

Method Summary

Modifier and Type	Method	Description
<R> Future<R>	andThen(Future<? extends R> next)
<R> Future<R>	ap(Future<Function1<? super T,? extends R>> apply)
(package private) static <T> Future<T>	async(Executor executor, Consumer1<Consumer1<? super Try<? extends T>>> consumer)
Try<T>	await()
Try<T>	await(Duration timeout)
(package private) static <T, R> Future<R>	bracket(Executor executor, Future<? extends T> acquire, Function1<? super T,? extends Future<? extends R>> use, Consumer1<? super T> release)
void	cancel(boolean mayInterruptThread)
private <R> Future<R>	chain(Function1<? super Try<? extends T>,? extends Kind<Future<?>,? extends R>> mapper)
Future<T>	filter(Matcher1<? super T> matcher)
<R> Future<R>	flatMap(Function1<? super T,? extends Kind<Future<?>,? extends R>> mapper)
<U> Future<U>	fold(Function1<? super Throwable,? extends U> failureMapper, Function1<? super T,? extends U> successMapper)
(package private) static <T> Future<T>	from(Executor executor, Promise<? extends T> promise)
boolean	isCancelled()
boolean	isCompleted()
<R> Future<R>	map(Function1<? super T,? extends R> mapper)
Future<T>	mapError(Function1<? super Throwable,? extends Throwable> mapper)
Future<T>	onComplete(Consumer1<? super Try<? extends T>> consumer)
Future<T>	onFailure(Consumer1<? super Throwable> consumer)
Future<T>	onSuccess(Consumer1<? super T> consumer)
Future<T>	orElse(Future<? extends T> other)
<X extends Throwable> Future<T>	recoverWith(Class<X> type, Function1<? super X,? extends T> mapper)
(package private) static Future<Unit>	sleep(Executor executor, Duration delay)
(package private) static <T> Future<T>	sync(Executor executor, Try<? extends T> result)
(package private) static <T> Future<T>	task(Executor executor, Producer<? extends Try<? extends T>> producer)
Promise<T>	toPromise()
String	toString()
private <R> Future<R>	transform(Function1<? super Try<? extends T>,? extends Try<? extends R>> mapper)

Methods inherited from class java.lang.Object

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

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

andThen

Methods inherited from interface com.github.tonivade.purefun.concurrent.Future

filterNot, get, getCause, getOrElse, getOrElse, getOrElseThrow, getOrElseThrow, recover, toCompletableFuture

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

fix, kind

Field Details

executor

private final Executor executor

propagate

private final Propagate propagate

promise

private final Promise<T> promise

cancellable

private final Cancellable cancellable

uuid

private final UUID uuid

Constructor Details

FutureImpl

private FutureImpl(Executor executor,
 Callback<T> callback)

FutureImpl

private FutureImpl(Executor executor,
 Callback<T> callback,
 Propagate propagate)

Method Details

onComplete

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

Specified by:

onComplete in interface Future<T>

onSuccess

public Future<T> onSuccess(Consumer1<? super T> consumer)

Specified by:

onSuccess in interface Future<T>

onFailure

public Future<T> onFailure(Consumer1<? super Throwable> consumer)

Specified by:

onFailure in interface Future<T>

isCompleted

public boolean isCompleted()

Specified by:

isCompleted in interface Future<T>

isCancelled

public boolean isCancelled()

Specified by:

isCancelled in interface Future<T>

await

public Try<T> await()

Specified by:

await in interface Future<T>

await

public Try<T> await(Duration timeout)

Specified by:

await in interface Future<T>

map

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

Specified by:

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

Specified by:

map in interface Future<T>

Specified by:

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

mapError

public Future<T> mapError(Function1<? super Throwable,? extends Throwable> mapper)

Specified by:

mapError in interface Future<T>

flatMap

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

Specified by:

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

Specified by:

flatMap in interface Future<T>

andThen

public <R> Future<R> andThen(Future<? extends R> next)

Specified by:

andThen in interface Future<T>

ap

public <R> Future<R> ap(Future<Function1<? super T,? extends R>> apply)

Specified by:

ap in interface Future<T>

filter

public Future<T> filter(Matcher1<? super T> matcher)

Specified by:

filter in interface Future<T>

orElse

public Future<T> orElse(Future<? extends T> other)

Specified by:

orElse in interface Future<T>

recoverWith

public <X extends Throwable> Future<T> recoverWith(Class<X> type,
 Function1<? super X,? extends T> mapper)

Specified by:

recoverWith in interface Future<T>

fold

public <U> Future<U> fold(Function1<? super Throwable,? extends U> failureMapper,
 Function1<? super T,? extends U> successMapper)

Specified by:

fold in interface Future<T>

cancel

public void cancel(boolean mayInterruptThread)

Specified by:

cancel in interface Future<T>

toPromise

public Promise<T> toPromise()

Specified by:

toPromise in interface Future<T>

toString

public String toString()

Overrides:

toString in class Object

transform

private <R> Future<R> transform(Function1<? super Try<? extends T>,? extends Try<? extends R>> mapper)

chain

private <R> Future<R> chain(Function1<? super Try<? extends T>,? extends Kind<Future<?>,? extends R>> mapper)

sync

static <T> Future<T> sync(Executor executor,
 Try<? extends T> result)

task

static <T> Future<T> task(Executor executor,
 Producer<? extends Try<? extends T>> producer)

async

static <T> Future<T> async(Executor executor,
 Consumer1<Consumer1<? super Try<? extends T>>> consumer)

from

static <T> Future<T> from(Executor executor,
 Promise<? extends T> promise)

sleep

static Future<Unit> sleep(Executor executor,
 Duration delay)

bracket

static <T,
R> Future<R> bracket(Executor executor,
 Future<? extends T> acquire,
 Function1<? super T,? extends Future<? extends R>> use,
 Consumer1<? super T> release)