From 7d7cb1866c2330cefbd31ed197300819f0605583 Mon Sep 17 00:00:00 2001
From: Grzegorz Piwowarek <gpiwowarek@gmail.com>
Date: Thu, 12 Oct 2023 08:57:31 +0200
Subject: [PATCH] Improve internal naming (#791)

---
 .../collectors/AsyncParallelCollector.java       | 16 ++++++++--------
 1 file changed, 8 insertions(+), 8 deletions(-)

diff --git a/src/main/java/com/pivovarit/collectors/AsyncParallelCollector.java b/src/main/java/com/pivovarit/collectors/AsyncParallelCollector.java
index e2d4b48a..bb7c44d1 100644
--- a/src/main/java/com/pivovarit/collectors/AsyncParallelCollector.java
+++ b/src/main/java/com/pivovarit/collectors/AsyncParallelCollector.java
@@ -29,16 +29,16 @@ final class AsyncParallelCollector<T, R, C>
   implements Collector<T, List<CompletableFuture<R>>, CompletableFuture<C>> {
 
     private final Dispatcher<R> dispatcher;
-    private final Function<T, R> mapper;
-    private final Function<Stream<R>, C> processor;
+    private final Function<T, R> task;
+    private final Function<Stream<R>, C> finalizer;
 
     private AsyncParallelCollector(
-      Function<T, R> mapper,
+      Function<T, R> task,
       Dispatcher<R> dispatcher,
-      Function<Stream<R>, C> processor) {
+      Function<Stream<R>, C> finalizer) {
         this.dispatcher = dispatcher;
-        this.processor = processor;
-        this.mapper = mapper;
+        this.finalizer = finalizer;
+        this.task = task;
     }
 
     @Override
@@ -55,12 +55,12 @@ public BinaryOperator<List<CompletableFuture<R>>> combiner() {
 
     @Override
     public BiConsumer<List<CompletableFuture<R>>, T> accumulator() {
-        return (acc, e) -> acc.add(dispatcher.enqueue(() -> mapper.apply(e)));
+        return (acc, e) -> acc.add(dispatcher.enqueue(() -> task.apply(e)));
     }
 
     @Override
     public Function<List<CompletableFuture<R>>, CompletableFuture<C>> finisher() {
-        return futures -> combine(futures).thenApply(processor);
+        return futures -> combine(futures).thenApply(finalizer);
     }
 
     @Override