Index
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, - Class in com.pivovarit.collectorsC> - 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>, 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>, 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 theParallelCollectors
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.Dispatcher
- dispatcher - Variable in class com.pivovarit.collectors.ParallelStreamCollector
- Dispatcher<T> - Class in com.pivovarit.collectors
- Dispatcher() - 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 asCompletableFuture
containing aStream
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 customExecutor
and returning them asCompletableFuture
containing aStream
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 customExecutor
and returning them asCompletableFuture
containing aStream
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 aCompletableFuture
containing a result of the application of the user-providedCollector
. - 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 customExecutor
and returning them as aCompletableFuture
containing a result of the application of the user-providedCollector
. - 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 customExecutor
and returning them as aCompletableFuture
containing a result of the application of the user-providedCollector
. - parallel.collectors - module parallel.collectors
- ParallelCollectors - Class in com.pivovarit.collectors
-
An umbrella class exposing static factory methods for instantiating parallel
Collector
s - 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
- parallelToOrderedStream(Function<T, R>, Executor, int) - Static method in class com.pivovarit.collectors.ParallelCollectors.Batching
- parallelToOrderedStream(Function<T, R>, Executor, int) - Static method in class com.pivovarit.collectors.ParallelCollectors
- parallelToStream(Function<T, R>) - Static method in class com.pivovarit.collectors.ParallelCollectors
- parallelToStream(Function<T, R>, Executor, int) - Static method in class com.pivovarit.collectors.ParallelCollectors.Batching
- parallelToStream(Function<T, R>, Executor, int) - Static method in class com.pivovarit.collectors.ParallelCollectors
- 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
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>, 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>, 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 aStream<CompletableFuture<T>>
into aCompletableFuture<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 aStream<CompletableFuture<T>>
into aCompletableFuture<R>
using a providedCollector<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
W
- workingQueue - Variable in class com.pivovarit.collectors.Dispatcher
All Classes and Interfaces|All Packages