com.inductiveautomation.ignition.common.util

Class Futures

java.lang.Object

com.inductiveautomation.ignition.common.util.Futures

public class Futures
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
Futures()

Method Summary

Modifier and Type	Method and Description
static <T> java.util.concurrent.CompletableFuture<T>	failedFuture(java.lang.Throwable ex) Return a CompletableFuture that has been completed exceptionally using the provided Throwable.
static <T> T	getSafe(java.util.concurrent.CompletableFuture<T> cf)
static <T> java.util.concurrent.CompletableFuture<java.util.List<T>>	sequence(java.util.concurrent.CompletableFuture<T>[] futures)
static <T> java.util.concurrent.CompletableFuture<java.util.List<T>>	sequence(java.util.List<java.util.concurrent.CompletableFuture<T>> futures)
static <T> java.util.concurrent.CompletableFuture<java.util.List<T>>	sequence(java.util.stream.Stream<java.util.concurrent.CompletableFuture<T>> stream)

Methods inherited from class java.lang.Object

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

Constructor Detail

Futures

public Futures()

Method Detail

failedFuture

public static <T> java.util.concurrent.CompletableFuture<T> failedFuture(java.lang.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> java.util.concurrent.CompletableFuture<java.util.List<T>> sequence(java.util.stream.Stream<java.util.concurrent.CompletableFuture<T>> stream)

sequence

public static <T> java.util.concurrent.CompletableFuture<java.util.List<T>> sequence(java.util.List<java.util.concurrent.CompletableFuture<T>> futures)

sequence

public static <T> java.util.concurrent.CompletableFuture<java.util.List<T>> sequence(java.util.concurrent.CompletableFuture<T>[] futures)

getSafe

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