Package com.github.tonivade.purefun.concurrent

Class PromiseImpl<T>

java.lang.Object

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

All Implemented Interfaces:

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

final class PromiseImpl<T>
extends Object
implements Promise<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>

Field Summary

Fields

Modifier and Type	Field	Description
private final Condition	condition
private final Queue<Consumer1<? super Try<? extends T>>>	consumers
private final Executor	executor
private final ReentrantLock	lock
private final AtomicReference<Try<? extends T>>	reference

Constructor Summary

Constructors

Constructor	Description
PromiseImpl(Executor executor)

Method Summary

Modifier and Type	Method	Description
<R> Promise<R>	ap(Kind<Promise<?>,? extends Function1<? super T,? extends R>> apply)
Try<T>	await()
Try<T>	await(Duration timeout)
private Option<Try<T>>	current(Consumer1<? super Try<? extends T>> consumer)
<R> Promise<R>	flatMap(Function1<? super T,? extends Kind<Promise<?>,? extends R>> mapper)
boolean	isCompleted()
private boolean	isEmpty()
<R> Promise<R>	map(Function1<? super T,? extends R> mapper)
Promise<T>	onComplete(Consumer1<? super Try<? extends T>> consumer)
private Try<T>	safeGet()
private void	set(Try<? extends T> value)
private void	submit(Try<? extends T> value, Consumer1<? super Try<? extends T>> consumer)
boolean	tryComplete(Try<? extends T> value)

Methods inherited from class java.lang.Object

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

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

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

andThen, cancel, complete, failed, onFailure, onSuccess, succeeded, then, thenRun

Field Details

lock

private final ReentrantLock lock

condition

private final Condition condition

consumers

private final Queue<Consumer1<? super Try<? extends T>>> consumers

reference

private final AtomicReference<Try<? extends T>> reference

executor

private final Executor executor

Constructor Details

PromiseImpl

PromiseImpl(Executor executor)

Method Details

tryComplete

public boolean tryComplete(Try<? extends T> value)

Specified by:

tryComplete in interface Promise<T>

await

public Try<T> await()

Specified by:

await in interface Promise<T>

await

public Try<T> await(Duration timeout)

Specified by:

await in interface Promise<T>

isCompleted

public boolean isCompleted()

Specified by:

isCompleted in interface Promise<T>

onComplete

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

Specified by:

onComplete in interface Promise<T>

ap

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

Specified by:

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

Specified by:

ap in interface Promise<T>

map

public <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>

Specified by:

map in interface Promise<T>

flatMap

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

Specified by:

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

Specified by:

flatMap in interface Promise<T>

current

private Option<Try<T>> current(Consumer1<? super Try<? extends T>> consumer)

safeGet

private Try<T> safeGet()

set

private void set(Try<? extends T> value)

isEmpty

private boolean isEmpty()

submit

private void submit(Try<? extends T> value,
 Consumer1<? super Try<? extends T>> consumer)