Index

A B C D E F H I L M N O P R S T U V W 
All Classes and Interfaces|All Packages

A

accumulator() - Method in class com.pivovarit.collectors.AsyncParallelCollector
 
accumulator() - Method in class com.pivovarit.collectors.ParallelStreamCollector
 
apply(List<CompletableFuture<T>>) - Method in class com.pivovarit.collectors.CompletionStrategy.Ordered
 
apply(List<CompletableFuture<T>>) - Method in class com.pivovarit.collectors.CompletionStrategy.Unordered
 
asSingletonListStream(List<T>) - Static method in class com.pivovarit.collectors.BatchingSpliterator
 
asyncCollector(Function<T, R>, Executor, Function<Stream<R>, RR>) - Static method in class com.pivovarit.collectors.AsyncParallelCollector
 
AsyncParallelCollector<T,R,C> - Class in com.pivovarit.collectors
 
AsyncParallelCollector(Function<T, R>, Dispatcher<R>, Function<Stream<R>, C>) - Constructor for class com.pivovarit.collectors.AsyncParallelCollector
 
AsyncParallelCollector.BatchingCollectors - Class in com.pivovarit.collectors
 

B

backingTask - Variable in class com.pivovarit.collectors.Dispatcher.InterruptibleCompletableFuture
 
batching(Function<T, R>) - Static method in class com.pivovarit.collectors.BatchingSpliterator
 
Batching() - Constructor for class com.pivovarit.collectors.ParallelCollectors.Batching
 
batchingCollector(Function<T, R>, Executor, int) - Static method in class com.pivovarit.collectors.ParallelStreamCollector.BatchingCollectors
 
batchingCollector(Function<T, R>, Executor, int, Function<Stream<R>, RR>) - Static method in class com.pivovarit.collectors.AsyncParallelCollector.BatchingCollectors
 
BatchingCollectors() - Constructor for class com.pivovarit.collectors.AsyncParallelCollector.BatchingCollectors
 
BatchingCollectors() - Constructor for class com.pivovarit.collectors.ParallelStreamCollector.BatchingCollectors
 
BatchingSpliterator<T> - Class in com.pivovarit.collectors
 
BatchingSpliterator(List<T>, int) - Constructor for class com.pivovarit.collectors.BatchingSpliterator
 

C

cancel(boolean) - Method in class com.pivovarit.collectors.Dispatcher.InterruptibleCompletableFuture
 
characteristics - Variable in class com.pivovarit.collectors.ParallelStreamCollector
 
characteristics() - Method in class com.pivovarit.collectors.AsyncParallelCollector
 
characteristics() - Method in class com.pivovarit.collectors.BatchingSpliterator
 
characteristics() - Method in class com.pivovarit.collectors.CompletionOrderSpliterator
 
characteristics() - Method in class com.pivovarit.collectors.ParallelStreamCollector
 
chunks - Variable in class com.pivovarit.collectors.BatchingSpliterator
 
chunkSize - Variable in class com.pivovarit.collectors.BatchingSpliterator
 
collectingToStream(Function<T, R>) - Static method in class com.pivovarit.collectors.AsyncParallelCollector
 
collectingToStream(Function<T, R>, int) - Static method in class com.pivovarit.collectors.AsyncParallelCollector
 
collectingToStream(Function<T, R>, Executor, int) - Static method in class com.pivovarit.collectors.AsyncParallelCollector.BatchingCollectors
 
collectingToStream(Function<T, R>, Executor, int) - Static method in class com.pivovarit.collectors.AsyncParallelCollector
 
collectingWithCollector(Collector<R, ?, RR>, Function<T, R>) - Static method in class com.pivovarit.collectors.AsyncParallelCollector
 
collectingWithCollector(Collector<R, ?, RR>, Function<T, R>, int) - Static method in class com.pivovarit.collectors.AsyncParallelCollector
 
collectingWithCollector(Collector<R, ?, RR>, Function<T, R>, Executor, int) - Static method in class com.pivovarit.collectors.AsyncParallelCollector.BatchingCollectors
 
collectingWithCollector(Collector<R, ?, RR>, Function<T, R>, Executor, int) - Static method in class com.pivovarit.collectors.AsyncParallelCollector
 
com.pivovarit.collectors - package com.pivovarit.collectors
The com.pivovarit.collectors package contains all internal components backing the ParallelCollectors APIs
combine(List<CompletableFuture<T>>) - Static method in class com.pivovarit.collectors.AsyncParallelCollector
 
combiner() - Method in class com.pivovarit.collectors.AsyncParallelCollector
 
combiner() - Method in class com.pivovarit.collectors.ParallelStreamCollector
 
completed - Variable in class com.pivovarit.collectors.CompletionOrderSpliterator
 
completedBy(FutureTask<Void>) - Method in class com.pivovarit.collectors.Dispatcher.InterruptibleCompletableFuture
 
CompletionOrderSpliterator<T> - Class in com.pivovarit.collectors
 
CompletionOrderSpliterator(List<CompletableFuture<T>>) - Constructor for class com.pivovarit.collectors.CompletionOrderSpliterator
 
completionSignaller - Variable in class com.pivovarit.collectors.Dispatcher
 
completionStrategy - Variable in class com.pivovarit.collectors.ParallelStreamCollector
 
CompletionStrategy<T> - Interface in com.pivovarit.collectors
 
CompletionStrategy.Ordered<T> - Class in com.pivovarit.collectors
 
CompletionStrategy.Unordered<T> - Class in com.pivovarit.collectors
 
completionTask(Supplier<T>, Dispatcher.InterruptibleCompletableFuture<T>) - Method in class com.pivovarit.collectors.Dispatcher
 
consumed - Variable in class com.pivovarit.collectors.BatchingSpliterator
 

D

defaultExecutorService() - Static method in class com.pivovarit.collectors.Dispatcher
 
dispatcher - Variable in class com.pivovarit.collectors.AsyncParallelCollector
 
dispatcher - Variable in class com.pivovarit.collectors.ParallelStreamCollector
 
Dispatcher<T> - Class in com.pivovarit.collectors
 
Dispatcher() - Constructor for class com.pivovarit.collectors.Dispatcher
 
Dispatcher(int) - Constructor for class com.pivovarit.collectors.Dispatcher
 
Dispatcher(Executor, int) - Constructor for class com.pivovarit.collectors.Dispatcher
 
Dispatcher.InterruptibleCompletableFuture<T> - Class in com.pivovarit.collectors
 

E

enqueue(Supplier<T>) - Method in class com.pivovarit.collectors.Dispatcher
 
estimateSize() - Method in class com.pivovarit.collectors.BatchingSpliterator
 
estimateSize() - Method in class com.pivovarit.collectors.CompletionOrderSpliterator
 
executor - Variable in class com.pivovarit.collectors.Dispatcher
 

F

finalizer - Variable in class com.pivovarit.collectors.AsyncParallelCollector
 
finisher() - Method in class com.pivovarit.collectors.AsyncParallelCollector
 
finisher() - Method in class com.pivovarit.collectors.ParallelStreamCollector
 
from(Executor, int) - Static method in class com.pivovarit.collectors.Dispatcher
 
function - Variable in class com.pivovarit.collectors.ParallelStreamCollector
 
FutureCollectors - Class in com.pivovarit.collectors
 
FutureCollectors() - Constructor for class com.pivovarit.collectors.FutureCollectors
 

H

handle(Throwable) - Method in class com.pivovarit.collectors.Dispatcher
 

I

initialSize - Variable in class com.pivovarit.collectors.CompletionOrderSpliterator
 
InterruptibleCompletableFuture() - Constructor for class com.pivovarit.collectors.Dispatcher.InterruptibleCompletableFuture
 
isRunning() - Method in class com.pivovarit.collectors.Dispatcher
 

L

limiter - Variable in class com.pivovarit.collectors.Dispatcher
 

M

maxChunks - Variable in class com.pivovarit.collectors.BatchingSpliterator
 

N

nextCompleted() - Method in class com.pivovarit.collectors.CompletionOrderSpliterator
 

O

ordered() - Static method in interface com.pivovarit.collectors.CompletionStrategy
 
Ordered() - Constructor for class com.pivovarit.collectors.CompletionStrategy.Ordered
 
ORDERED - Static variable in interface com.pivovarit.collectors.CompletionStrategy
 

P

parallel(Function<T, R>) - 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<T, R>, 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<T, R>, 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<T, R>, 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<T, R>, Collector<R, ?, RR>) - 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<T, R>, Collector<R, ?, RR>, 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<T, R>, Collector<R, ?, RR>, 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<T, R>, Collector<R, ?, RR>, 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() - Constructor for class com.pivovarit.collectors.ParallelCollectors
 
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)
ParallelStreamCollector<T,R> - Class in com.pivovarit.collectors
 
ParallelStreamCollector(Function<T, R>, CompletionStrategy<R>, Set<Collector.Characteristics>, Dispatcher<R>) - Constructor for class com.pivovarit.collectors.ParallelStreamCollector
 
ParallelStreamCollector.BatchingCollectors - Class in com.pivovarit.collectors
 
parallelToOrderedStream(Function<T, R>) - 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<T, R>, 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<T, R>, 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<T, R>, 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<T, R>) - 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<T, R>, 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<T, R>, 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<T, R>, 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.
partitioned(List<T>, int) - Static method in class com.pivovarit.collectors.BatchingSpliterator
 
POISON_PILL - Static variable in class com.pivovarit.collectors.Dispatcher
 

R

remaining - Variable in class com.pivovarit.collectors.CompletionOrderSpliterator
 
requireValidExecutor(Executor) - Static method in class com.pivovarit.collectors.Dispatcher
 
requireValidParallelism(int) - Static method in class com.pivovarit.collectors.AsyncParallelCollector
 
retry(Runnable) - Static method in class com.pivovarit.collectors.Dispatcher
 

S

shortcircuit(Dispatcher.InterruptibleCompletableFuture<?>) - Static method in class com.pivovarit.collectors.Dispatcher
 
shortCircuited - Variable in class com.pivovarit.collectors.Dispatcher
 
source - Variable in class com.pivovarit.collectors.BatchingSpliterator
 
start() - Method in class com.pivovarit.collectors.Dispatcher
 
started - Variable in class com.pivovarit.collectors.Dispatcher
 
stop() - Method in class com.pivovarit.collectors.Dispatcher
 
streaming(Function<T, R>) - Static method in class com.pivovarit.collectors.ParallelStreamCollector
 
streaming(Function<T, R>, int) - Static method in class com.pivovarit.collectors.ParallelStreamCollector
 
streaming(Function<T, R>, Executor, int) - Static method in class com.pivovarit.collectors.ParallelStreamCollector.BatchingCollectors
 
streaming(Function<T, R>, Executor, int) - Static method in class com.pivovarit.collectors.ParallelStreamCollector
 
streamingOrdered(Function<T, R>) - Static method in class com.pivovarit.collectors.ParallelStreamCollector
 
streamingOrdered(Function<T, R>, int) - Static method in class com.pivovarit.collectors.ParallelStreamCollector
 
streamingOrdered(Function<T, R>, Executor, int) - Static method in class com.pivovarit.collectors.ParallelStreamCollector.BatchingCollectors
 
streamingOrdered(Function<T, R>, Executor, int) - Static method in class com.pivovarit.collectors.ParallelStreamCollector
 
supplier() - Method in class com.pivovarit.collectors.AsyncParallelCollector
 
supplier() - Method in class com.pivovarit.collectors.ParallelStreamCollector
 
syncCollector(Function<T, R>) - Static method in class com.pivovarit.collectors.ParallelStreamCollector.BatchingCollectors
 

T

task - Variable in class com.pivovarit.collectors.AsyncParallelCollector
 
toFuture() - Static method in class com.pivovarit.collectors.FutureCollectors
 
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<T, ?, R>) - Static method in class com.pivovarit.collectors.FutureCollectors
 
toFuture(Collector<T, ?, R>) - 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>
tryAdvance(Consumer<? super List<T>>) - Method in class com.pivovarit.collectors.BatchingSpliterator
 
tryAdvance(Consumer<? super T>) - Method in class com.pivovarit.collectors.CompletionOrderSpliterator
 
trySplit() - Method in class com.pivovarit.collectors.BatchingSpliterator
 
trySplit() - Method in class com.pivovarit.collectors.CompletionOrderSpliterator
 

U

unordered() - Static method in interface com.pivovarit.collectors.CompletionStrategy
 
Unordered() - Constructor for class com.pivovarit.collectors.CompletionStrategy.Unordered
 
UNORDERED - Static variable in interface com.pivovarit.collectors.CompletionStrategy
 
UNORDERED - Static variable in class com.pivovarit.collectors.ParallelStreamCollector
 

V

virtual() - Static method in class com.pivovarit.collectors.Dispatcher
 
virtual(int) - Static method in class com.pivovarit.collectors.Dispatcher
 

W

workingQueue - Variable in class com.pivovarit.collectors.Dispatcher
 
A B C D E F H I L M N O P R S T U V W 
All Classes and Interfaces|All Packages