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) - Method in class com.pivovarit.collectors.CompletionStrategy.Ordered
apply(List) - Method in class com.pivovarit.collectors.CompletionStrategy.Unordered
asSingletonListStream(List) - Static method in class com.pivovarit.collectors.BatchingSpliterator
asyncCollector(Function, Executor, Function) - Static method in class com.pivovarit.collectors.AsyncParallelCollector
AsyncParallelCollector<T,R,C> - Class in com.pivovarit.collectors
AsyncParallelCollector(Function, Dispatcher, Function) - 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) - Static method in class com.pivovarit.collectors.BatchingSpliterator
Batching() - Constructor for class com.pivovarit.collectors.ParallelCollectors.Batching
batchingCollector(Function, Executor, int) - Static method in class com.pivovarit.collectors.ParallelStreamCollector.BatchingCollectors
batchingCollector(Function, Executor, int, Function) - 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, 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) - Static method in class com.pivovarit.collectors.AsyncParallelCollector
collectingToStream(Function, int) - Static method in class com.pivovarit.collectors.AsyncParallelCollector
collectingToStream(Function, Executor, int) - Static method in class com.pivovarit.collectors.AsyncParallelCollector.BatchingCollectors
collectingToStream(Function, Executor, int) - Static method in class com.pivovarit.collectors.AsyncParallelCollector
collectingWithCollector(Collector, Function) - Static method in class com.pivovarit.collectors.AsyncParallelCollector
collectingWithCollector(Collector, Function, int) - Static method in class com.pivovarit.collectors.AsyncParallelCollector
collectingWithCollector(Collector, Function, Executor, int) - Static method in class com.pivovarit.collectors.AsyncParallelCollector.BatchingCollectors
collectingWithCollector(Collector, Function, 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) - 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) - Method in class com.pivovarit.collectors.Dispatcher.InterruptibleCompletableFuture
CompletionOrderSpliterator<T> - Class in com.pivovarit.collectors
CompletionOrderSpliterator(List) - 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, Dispatcher.InterruptibleCompletableFuture) - 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) - 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) - 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() - 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, CompletionStrategy, Set, Dispatcher) - Constructor for class com.pivovarit.collectors.ParallelStreamCollector
ParallelStreamCollector.BatchingCollectors - Class in com.pivovarit.collectors
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.
partitioned(List, 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) - Static method in class com.pivovarit.collectors.ParallelStreamCollector
streaming(Function, int) - Static method in class com.pivovarit.collectors.ParallelStreamCollector
streaming(Function, Executor, int) - Static method in class com.pivovarit.collectors.ParallelStreamCollector.BatchingCollectors
streaming(Function, Executor, int) - Static method in class com.pivovarit.collectors.ParallelStreamCollector
streamingOrdered(Function) - Static method in class com.pivovarit.collectors.ParallelStreamCollector
streamingOrdered(Function, int) - Static method in class com.pivovarit.collectors.ParallelStreamCollector
streamingOrdered(Function, Executor, int) - Static method in class com.pivovarit.collectors.ParallelStreamCollector.BatchingCollectors
streamingOrdered(Function, 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) - 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) - Static method in class com.pivovarit.collectors.FutureCollectors
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>
tryAdvance(Consumer) - Method in class com.pivovarit.collectors.BatchingSpliterator
tryAdvance(Consumer) - 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