Package io.weaviate.client.base.util

Class Futures

java.lang.Object

io.weaviate.client.base.util.Futures

public class Futures
extends Object

Method Summary

Modifier and Type	Method	Description
static <T> CompletableFuture<T>	handleAsync(CompletableFuture<T> future, BiFunction<T,Throwable,CompletableFuture<T>> callback, Executor executor)
static <T> CompletableFuture<T>	supplyAsync(Supplier<T> supplier, Executor executor)
static <T> CompletableFuture<T>	supplyDelayed(Supplier<CompletableFuture<T>> supplier, long millis, Executor executor)
static <T, U> CompletableFuture<U>	thenComposeAsync(CompletableFuture<T> future, Function<T,CompletableFuture<U>> callback, Executor executor)

Methods inherited from class java.lang.Object

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

Method Details

supplyDelayed

public static <T> CompletableFuture<T> supplyDelayed(Supplier<CompletableFuture<T>> supplier,
 long millis,
 Executor executor)
                                              throws InterruptedException

Throws:

InterruptedException

thenComposeAsync

public static <T,
U> CompletableFuture<U> thenComposeAsync(CompletableFuture<T> future,
 Function<T,CompletableFuture<U>> callback,
 Executor executor)

handleAsync

public static <T> CompletableFuture<T> handleAsync(CompletableFuture<T> future,
 BiFunction<T,Throwable,CompletableFuture<T>> callback,
 Executor executor)

supplyAsync

public static <T> CompletableFuture<T> supplyAsync(Supplier<T> supplier,
 Executor executor)