Uses of Class
com.github.robtimus.stream.FutureValue

Uses of FutureValue in com.github.robtimus.stream

Methods in com.github.robtimus.stream that return FutureValue

Modifier and Type	Method and Description
static <T> FutureValue<T>	FutureValue.wrap(CompletableFuture<T> future) Wraps a CompletableFuture in a FutureValue.
static <T> FutureValue<T>	FutureValue.wrap(CompletionStage<T> future) Wraps a CompletionStage in a FutureValue.

Methods in com.github.robtimus.stream that return types with arguments of type FutureValue

Modifier and Type	Method and Description
static <T,A,R> Collector<FutureValue<T>,?,CompletableFuture<R>>	FutureValue.collect(Collector<T,A,R> collector) Returns a Collector that accumulates FutureValue instances into a CompletableFuture.
static <T> UnaryOperator<FutureValue<T>>	FutureValue.filter(Predicate<? super T> predicate) Returns a unary operator that applies filtering to a stream of FutureValue.
static <T> Collector<FutureValue<T>,?,CompletableFuture<Optional<T>>>	FutureValue.findAny() Returns a Collector that returns any CompletionStage result.
static <T> Collector<FutureValue<T>,?,CompletableFuture<Optional<T>>>	FutureValue.findAny(ExecutorService executor) Returns a Collector that returns any CompletionStage result.
static <T,R> Function<FutureValue<T>,FutureValue<R>>	FutureValue.flatMap(Function<? super T,? extends CompletionStage<R>> mapper) Returns a function that transforms one FutureValue instance into another.
static <T,R> Function<FutureValue<T>,FutureValue<R>>	FutureValue.flatMap(Function<? super T,? extends CompletionStage<R>> mapper) Returns a function that transforms one FutureValue instance into another.
static <T,R> Function<FutureValue<T>,FutureValue<R>>	FutureValue.map(Function<? super T,? extends R> mapper) Returns a function that transforms one FutureValue instance into another.
static <T,R> Function<FutureValue<T>,FutureValue<R>>	FutureValue.map(Function<? super T,? extends R> mapper) Returns a function that transforms one FutureValue instance into another.
static <T> Consumer<FutureValue<T>>	FutureValue.run(Consumer<? super T> action) Returns a consumer that performs an action on FutureValue instances.