Package com.inductiveautomation.ignition.common.util

Class Futures

java.lang.Object

com.inductiveautomation.ignition.common.util.Futures

public class Futures
extends Object

Constructor Summary

Constructors

Constructor	Description
Futures()

Method Summary

Modifier and Type	Method	Description
static <T> CompletableFuture<T>	failedFuture(Throwable ex)	Return a CompletableFuture that has been completed exceptionally using the provided Throwable.
static <T> T	getSafe(CompletableFuture<T> cf)
static <T> CompletableFuture<List<T>>	sequence(CompletableFuture<T>[] futures)
static <T> CompletableFuture<List<T>>	sequence(List<CompletableFuture<T>> futures)
static <T> CompletableFuture<List<T>>	sequence(Stream<CompletableFuture<T>> stream)
static <T, R, E extends Throwable> Function<T,CompletableFuture<R>>	wrap(FragileFunction<T,R,E> fragileFunction)

Methods inherited from class java.lang.Object

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

Constructor Details

Futures

public Futures()

Method Details

failedFuture

public static <T> CompletableFuture<T> failedFuture(Throwable ex)

Return a CompletableFuture that has been completed exceptionally using the provided Throwable.

Parameters:

ex - the Throwable to complete with.

Returns:

a CompletableFuture that has been completed exceptionally using the provided Throwable.

sequence

public static <T> CompletableFuture<List<T>> sequence(Stream<CompletableFuture<T>> stream)

sequence

public static <T> CompletableFuture<List<T>> sequence(List<CompletableFuture<T>> futures)

sequence

public static <T> CompletableFuture<List<T>> sequence(CompletableFuture<T>[] futures)

getSafe

public static <T> T getSafe(CompletableFuture<T> cf)

wrap

public static <T,
R,
E extends Throwable>
Function<T,CompletableFuture<R>> wrap(FragileFunction<T,R,E> fragileFunction)