diff --git a/src/main/java/com/pivovarit/collectors/ParallelCollectors.java b/src/main/java/com/pivovarit/collectors/ParallelCollectors.java index 1c008fc3..d611b974 100644 --- a/src/main/java/com/pivovarit/collectors/ParallelCollectors.java +++ b/src/main/java/com/pivovarit/collectors/ParallelCollectors.java @@ -17,36 +17,6 @@ public final class ParallelCollectors { private ParallelCollectors() { } - /** - * A convenience {@link Collector} used for executing parallel computations on a custom {@link Executor} - * and returning them as a {@link CompletableFuture} containing a result of the application of the user-provided {@link Collector}. - * - *

- * The maximum parallelism level defaults to {@code Runtime.availableProcessors() - 1} - * - *
- * Example: - *
{@code
-     * CompletableFuture> result = Stream.of(1, 2, 3)
-     *   .collect(parallel(i -> foo(i), toList(), executor));
-     * }
- * - * @param mapper a transformation to be performed in parallel - * @param collector the {@code Collector} describing the reduction - * @param executor the {@code Executor} to use for asynchronous execution - * @param the type of the collected elements - * @param the result returned by {@code mapper} - * @param the reduction result {@code collector} - * - * @return a {@code Collector} which collects all processed elements into a user-provided mutable {@code Collection} in parallel - * - * @since 2.0.0 - * @deprecated use {@link ParallelCollectors#parallel(Function, Collector, Executor, int)} - */ - public static Collector> parallel(Function mapper, Collector collector, Executor executor) { - return AsyncParallelCollector.collectingWithCollector(collector, mapper, executor); - } - /** * A convenience {@link Collector} used for executing parallel computations on a custom {@link Executor} * and returning them as a {@link CompletableFuture} containing a result of the application of the user-provided {@link Collector}. @@ -74,37 +44,6 @@ private ParallelCollectors() { return AsyncParallelCollector.collectingWithCollector(collector, mapper, executor, parallelism); } - /** - * A convenience {@link Collector} used for executing parallel computations on a custom {@link Executor} - * and returning them as {@link CompletableFuture} containing a {@link Stream} of these elements - * - *

- * The max parallelism level defaults to {@code Runtime.availableProcessors() - 1} but not less than 4 - * - *

- * The collector maintains the order of processed {@link Stream}. Instances should not be reused. - * - *
- * Example: - *
{@code
-     * CompletableFuture> result = Stream.of(1, 2, 3)
-     *   .collect(parallel(i -> foo(), executor));
-     * }
- * - * @param mapper a transformation to be performed in parallel - * @param executor the {@code Executor} to use for asynchronous execution - * @param the type of the collected elements - * @param the result returned by {@code mapper} - * - * @return a {@code Collector} which collects all processed elements into a {@code Stream} in parallel - * - * @since 2.0.0 - * @deprecated use {@link ParallelCollectors#parallel(Function, Executor, int)} - */ - public static Collector>> parallel(Function mapper, Executor executor) { - return AsyncParallelCollector.collectingToStream(mapper, executor); - } - /** * A convenience {@link Collector} used for executing parallel computations on a custom {@link Executor} * and returning them as {@link CompletableFuture} containing a {@link Stream} of these elements. @@ -133,40 +72,6 @@ private ParallelCollectors() { return AsyncParallelCollector.collectingToStream(mapper, executor, parallelism); } - /** - * A convenience {@link Collector} used for executing parallel computations on a custom {@link Executor} - * and returning a {@link Stream} instance returning results in completion order - *

- * For the parallelism of 1, the stream is executed by the calling thread. - * - *

- * The max parallelism level defaults to {@code Runtime.availableProcessors() - 1} but not less than 4 - * - *

- * Instances should not be reused. - * - *
- * Example: - *

{@code
-     * List result = Stream.of(1, 2, 3)
-     *   .collect(parallelToStream(i -> foo(), executor))
-     *   .collect(toList());
-     * }
- * - * @param mapper a transformation to be performed in parallel - * @param executor the {@code Executor} to use for asynchronous execution - * @param the type of the collected elements - * @param the result returned by {@code mapper} - * - * @return a {@code Collector} which collects all processed elements into a {@code Stream} in parallel - * - * @since 2.0.0 - * @deprecated use {@link ParallelCollectors#parallelToStream(Function, Executor, int)} - */ - public static Collector> parallelToStream(Function mapper, Executor executor) { - return ParallelStreamCollector.streaming(mapper, executor); - } - /** * A convenience {@link Collector} used for executing parallel computations on a custom {@link Executor} * and returning a {@link Stream} instance returning results as they arrive. @@ -195,39 +100,6 @@ private ParallelCollectors() { return ParallelStreamCollector.streaming(mapper, executor, parallelism); } - /** - * A convenience {@link Collector} used for executing parallel computations on a custom {@link Executor} - * and returning a {@link Stream} instance returning results as they arrive while maintaining the initial order. - *

- * For the parallelism of 1, the stream is executed by the calling thread. - * - *

- * The max parallelism level defaults to {@code Runtime.availableProcessors() - 1} but not less than 4 - * - *

- * Instances should not be reused. - *

- * Example: - *

{@code
-     * Stream.of(1, 2, 3)
-     *   .collect(parallelToOrderedStream(i -> foo(), executor))
-     *   .forEach(System.out::println);
-     * }
- * - * @param mapper a transformation to be performed in parallel - * @param executor the {@code Executor} to use for asynchronous execution - * @param the type of the collected elements - * @param the result returned by {@code mapper} - * - * @return a {@code Collector} which collects all processed elements into a {@code Stream} in parallel - * - * @since 2.0.0 - * @deprecated use {@link ParallelCollectors#parallelToOrderedStream(Function, Executor, int)} - */ - public static Collector> parallelToOrderedStream(Function mapper, Executor executor) { - return ParallelStreamCollector.streamingOrdered(mapper, executor); - } - /** * A convenience {@link Collector} used for executing parallel computations on a custom {@link Executor} * and returning a {@link Stream} instance returning results as they arrive while maintaining the initial order.