A C F M P R S T W

F

filter(Predicate<? super T>) - Static method in class com.github.robtimus.stream.FutureValue

Returns a unary operator that applies filtering to a stream of FutureValue.

findAny() - Static method in class com.github.robtimus.stream.FutureValue

Returns a Collector that returns any CompletionStage result.

findAny(ExecutorService) - Static method in class com.github.robtimus.stream.FutureValue

Returns a Collector that returns any CompletionStage result.

findSingle() - Static method in class com.github.robtimus.stream.AdditionalCollectors

Returns a Collector that finds the single element of a stream, or Optional.empty() if the stream is empty.

findSingle(Supplier<? extends RuntimeException>) - Static method in class com.github.robtimus.stream.AdditionalCollectors

Returns a Collector that finds the single element of a stream, or Optional.empty() if the stream is empty.

findUnique() - Static method in class com.github.robtimus.stream.AdditionalCollectors

Returns a Collector that finds a unique element of a stream, or Optional.empty() if the stream is empty.

findUnique(Supplier<? extends RuntimeException>) - Static method in class com.github.robtimus.stream.AdditionalCollectors

Returns a Collector that finds the unique element of a stream, or Optional.empty() if the stream is empty.

flatMap(Function<? super T, ? extends CompletionStage<R>>) - Static method in class com.github.robtimus.stream.FutureValue

Returns a function that transforms one FutureValue instance into another.

forEvery(int, Stream<T>, Collector<? super T, ?, R>, Consumer<? super R>) - Static method in class com.github.robtimus.stream.StreamUtils

Reduces elements of a stream in partitions of a specific size, then runs an action for each reduction result.

FutureValue<T> - Class in com.github.robtimus.stream

A class that allows filtering and mapping on CompletionStage instances inside streams.

A C F M P R S T W