Skip to content

Commit 7a89f40

Browse files
authored
Deprecate API methods with implicit parallelism resolution (#466)
1 parent 375b55e commit 7a89f40

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

src/main/java/com/pivovarit/collectors/ParallelCollectors.java

+8
Original file line numberDiff line numberDiff line change
@@ -41,7 +41,9 @@ private ParallelCollectors() {
4141
* @return a {@code Collector} which collects all processed elements into a user-provided mutable {@code Collection} in parallel
4242
*
4343
* @since 2.0.0
44+
* @deprecated use {@link ParallelCollectors#parallel(Function, Collector, Executor, int)}
4445
*/
46+
@Deprecated // for removal in 3.0.0
4547
public static <T, R, RR> Collector<T, ?, CompletableFuture<RR>> parallel(Function<T, R> mapper, Collector<R, ?, RR> collector, Executor executor) {
4648
return AsyncParallelCollector.collectingWithCollector(collector, mapper, executor);
4749
}
@@ -98,7 +100,9 @@ private ParallelCollectors() {
98100
* @return a {@code Collector} which collects all processed elements into a {@code Stream} in parallel
99101
*
100102
* @since 2.0.0
103+
* @deprecated use {@link ParallelCollectors#parallel(Function, Executor, int)}
101104
*/
105+
@Deprecated // for removal in 3.0.0
102106
public static <T, R> Collector<T, ?, CompletableFuture<Stream<R>>> parallel(Function<T, R> mapper, Executor executor) {
103107
return AsyncParallelCollector.collectingToStream(mapper, executor);
104108
}
@@ -162,7 +166,9 @@ private ParallelCollectors() {
162166
* @return a {@code Collector} which collects all processed elements into a {@code Stream} in parallel
163167
*
164168
* @since 2.0.0
169+
* @deprecated use {@link ParallelCollectors#parallelToStream(Function, Executor, int)}
165170
*/
171+
@Deprecated // for removal in 3.0.0
166172
public static <T, R> Collector<T, ?, Stream<R>> parallelToStream(Function<T, R> mapper, Executor executor) {
167173
return ParallelStreamCollector.streaming(mapper, executor);
168174
}
@@ -222,7 +228,9 @@ private ParallelCollectors() {
222228
* @return a {@code Collector} which collects all processed elements into a {@code Stream} in parallel
223229
*
224230
* @since 2.0.0
231+
* @deprecated use {@link ParallelCollectors#parallelToOrderedStream(Function, Executor, int)}
225232
*/
233+
@Deprecated // for removal in 3.0.0
226234
public static <T, R> Collector<T, ?, Stream<R>> parallelToOrderedStream(Function<T, R> mapper, Executor executor) {
227235
return ParallelStreamCollector.streamingOrdered(mapper, executor);
228236
}

0 commit comments

Comments
 (0)