+ rename

q3769 · May 15, 2024 · facf912 · facf912
1 parent eebaf80
commit facf912
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/main/java/conseq4j/execute/ConseqExecutor.java b/src/main/java/conseq4j/execute/ConseqExecutor.java
@@ -142,13 +142,13 @@ private static ConditionFactory await() {
     public <T> @NonNull Future<T> submit(@NonNull Callable<T> task, @NonNull Object sequenceKey) {
         CompletableFuture<?> taskCompletable = activeSequentialTasks.compute(
                 sequenceKey,
-                (k, presentTask) -> (presentTask == null)
+                (k, vCompletable) -> (vCompletable == null)
                         ? CompletableFuture.supplyAsync(() -> callUnchecked(task), workerExecutorService)
-                        : presentTask.handleAsync((r, e) -> callUnchecked(task), workerExecutorService));
+                        : vCompletable.handleAsync((r, e) -> callUnchecked(task), workerExecutorService));
         CompletableFuture<?> copy = taskCompletable.thenApply(r -> r);
         taskCompletable.whenCompleteAsync(
                 (r, e) -> activeSequentialTasks.computeIfPresent(
-                        sequenceKey, (k, checkedTask) -> checkedTask.isDone() ? null : checkedTask),
+                        sequenceKey, (k, vCompletable) -> vCompletable.isDone() ? null : vCompletable),
                 adminService);
         return (Future<T>) new DefensiveFuture<>(copy);
     }