Index

C P T 
All Classes and Interfaces|All Packages

C

com.pivovarit.collectors - package com.pivovarit.collectors
The com.pivovarit.collectors package contains all internal components backing the ParallelCollectors APIs

P

parallel(Function) - Static method in class com.pivovarit.collectors.ParallelCollectors
A convenience Collector used for executing parallel computations using Virtual Threads and returning them as CompletableFuture containing a Stream of these elements.
parallel(Function, int) - Static method in class com.pivovarit.collectors.ParallelCollectors
A convenience Collector used for executing parallel computations using Virtual Threads and returning them as CompletableFuture containing a Stream of these elements.
parallel(Function, Executor, int) - Static method in class com.pivovarit.collectors.ParallelCollectors.Batching
A convenience Collector used for executing parallel computations on a custom Executor and returning them as CompletableFuture containing a Stream of these elements.
parallel(Function, Executor, int) - Static method in class com.pivovarit.collectors.ParallelCollectors
A convenience Collector used for executing parallel computations on a custom Executor and returning them as CompletableFuture containing a Stream of these elements.
parallel(Function, Collector) - Static method in class com.pivovarit.collectors.ParallelCollectors
A convenience Collector used for executing parallel computations using Virtual Threads and returning them as a CompletableFuture containing a result of the application of the user-provided Collector.
parallel(Function, Collector, int) - Static method in class com.pivovarit.collectors.ParallelCollectors
A convenience Collector used for executing parallel computations using Virtual Threads and returning them as a CompletableFuture containing a result of the application of the user-provided Collector.
parallel(Function, Collector, Executor, int) - Static method in class com.pivovarit.collectors.ParallelCollectors.Batching
A convenience Collector used for executing parallel computations on a custom Executor and returning them as a CompletableFuture containing a result of the application of the user-provided Collector.
parallel(Function, Collector, Executor, int) - Static method in class com.pivovarit.collectors.ParallelCollectors
A convenience Collector used for executing parallel computations on a custom Executor and returning them as a CompletableFuture containing a result of the application of the user-provided Collector.
parallel.collectors - module parallel.collectors
 
ParallelCollectors - Class in com.pivovarit.collectors
An umbrella class exposing static factory methods for instantiating parallel Collectors
ParallelCollectors.Batching - Class in com.pivovarit.collectors
A subset of collectors which perform operations in batches and not separately (one object in a thread pool's worker queue represents a batch of operations to be performed by a single thread)
parallelToOrderedStream(Function) - Static method in class com.pivovarit.collectors.ParallelCollectors
A convenience Collector used for executing parallel computations using Virtual Threads and returning a Stream instance returning results as they arrive while maintaining the initial order.
parallelToOrderedStream(Function, int) - Static method in class com.pivovarit.collectors.ParallelCollectors
A convenience Collector used for executing parallel computations using Virtual Threads and returning a Stream instance returning results as they arrive while maintaining the initial order.
parallelToOrderedStream(Function, Executor, int) - Static method in class com.pivovarit.collectors.ParallelCollectors.Batching
A convenience Collector used for executing parallel computations on a custom Executor and returning a Stream instance returning results as they arrive while maintaining the initial order.
parallelToOrderedStream(Function, Executor, int) - Static method in class com.pivovarit.collectors.ParallelCollectors
A convenience Collector used for executing parallel computations on a custom Executor and returning a Stream instance returning results as they arrive while maintaining the initial order.
parallelToStream(Function) - Static method in class com.pivovarit.collectors.ParallelCollectors
A convenience Collector used for executing parallel computations using Virtual Threads and returning a Stream instance returning results as they arrive.
parallelToStream(Function, int) - Static method in class com.pivovarit.collectors.ParallelCollectors
A convenience Collector used for executing parallel computations using Virtual Threads and returning a Stream instance returning results as they arrive.
parallelToStream(Function, Executor, int) - Static method in class com.pivovarit.collectors.ParallelCollectors.Batching
A convenience Collector used for executing parallel computations on a custom Executor and returning a Stream instance returning results as they arrive.
parallelToStream(Function, Executor, int) - Static method in class com.pivovarit.collectors.ParallelCollectors
A convenience Collector used for executing parallel computations on a custom Executor and returning a Stream instance returning results as they arrive.

T

toFuture() - Static method in class com.pivovarit.collectors.ParallelCollectors
A convenience Collector for collecting a Stream<CompletableFuture<T>> into a CompletableFuture<List<T>>
toFuture(Collector) - Static method in class com.pivovarit.collectors.ParallelCollectors
A convenience Collector for collecting a Stream<CompletableFuture<T>> into a CompletableFuture<R> using a provided Collector<T, ?, R>
C P T 
All Classes and Interfaces|All Packages