com.aol.cyclops2.internal.react.async.future

Class FastFuture<T>

java.lang.Object

com.aol.cyclops2.internal.react.async.future.FastFuture<T>

public class FastFuture<T>
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	FastFuture.OnComplete

Constructor Summary

Constructors

Constructor and Description
FastFuture()
FastFuture(FinalPipeline pipeline, java.util.function.Consumer<FastFuture<T>> doFinally)
FastFuture(FinalPipeline pipeline, int max)

Method Summary

Modifier and Type	Method and Description
static <R> FastFuture<java.util.List<R>>	allOf(java.lang.Runnable onComplete, FastFuture... futures)
static <R> FastFuture<java.util.List<R>>	anyOf(FastFuture... futures)
void	await()
void	clearFast()
static <T> FastFuture<T>	completedFuture(T value)
void	essential(java.util.function.Consumer<FastFuture.OnComplete> fn) Called at least once on complete
static <T> FastFuture<T>	failedFuture(java.lang.Throwable t)
static <T> FastFuture<T>	fromCompletableFuture(java.util.concurrent.CompletableFuture<T> cf) Internal conversion method to convert CompletableFutures to FastFuture.
T	join() Join which can be called exactly once!
void	markComplete()
void	onComplete(java.util.function.Consumer<FastFuture.OnComplete> fn) Called at least once on complete
FastFuture<T>	populateFromCompletableFuture(java.util.concurrent.CompletableFuture<T> cf)
void	set(T result)
java.util.concurrent.CompletableFuture<T>	toCompletableFuture()
static <R> FastFuture<java.util.List<R>>	xOf(int x, java.lang.Runnable onComplete, FastFuture... futures)

Methods inherited from class java.lang.Object

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

Constructor Detail

FastFuture

public FastFuture()

FastFuture

public FastFuture(FinalPipeline pipeline,
                  java.util.function.Consumer<FastFuture<T>> doFinally)

FastFuture

public FastFuture(FinalPipeline pipeline,
                  int max)

Method Detail

await

public void await()

join

public T join()

Join which can be called exactly once!

Returns:

Result

markComplete

public void markComplete()

completedFuture

public static <T> FastFuture<T> completedFuture(T value)

toCompletableFuture

public java.util.concurrent.CompletableFuture<T> toCompletableFuture()

populateFromCompletableFuture

public FastFuture<T> populateFromCompletableFuture(java.util.concurrent.CompletableFuture<T> cf)

failedFuture

public static <T> FastFuture<T> failedFuture(java.lang.Throwable t)

fromCompletableFuture

public static <T> FastFuture<T> fromCompletableFuture(java.util.concurrent.CompletableFuture<T> cf)

Internal conversion method to convert CompletableFutures to FastFuture.

allOf

public static <R> FastFuture<java.util.List<R>> allOf(java.lang.Runnable onComplete,
                                                      FastFuture... futures)

xOf

public static <R> FastFuture<java.util.List<R>> xOf(int x,
                                                    java.lang.Runnable onComplete,
                                                    FastFuture... futures)

anyOf

public static <R> FastFuture<java.util.List<R>> anyOf(FastFuture... futures)

set

public void set(T result)

clearFast

public void clearFast()

essential

public void essential(java.util.function.Consumer<FastFuture.OnComplete> fn)

Called at least once on complete

onComplete

public void onComplete(java.util.function.Consumer<FastFuture.OnComplete> fn)

Called at least once on complete