WIP mostOf* using new orTimeout method

foldright · May 24, 2024 · 1650804 · 1650804
1 parent 9e68e0b
commit 1650804
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/cffu-core/src/main/java/io/foldright/cffu/CompletableFutureUtils.java b/cffu-core/src/main/java/io/foldright/cffu/CompletableFutureUtils.java
@@ -210,14 +210,14 @@ public static <T> CompletableFuture<List<T>> mostResultsOfSuccess(
             // defensive copy input cf in order to
             // avoid writing it by `completeOnTimeout` and read its result(`getSuccessNow`)
             final CompletableFuture<T> f = toCfCopy(cfs[0]);
-            return orTimeout(f, timeout, unit)
+            return orTimeout(f, timeout, unit, AsyncPoolHolder.ASYNC_POOL)
                     .handle((unused, ex) -> arrayList(getSuccessNow(f, valueIfNotSuccess)));
         }
 
         // MUST be *Non-Minimal* CF instances in order to read results(`getSuccessNow`),
         // otherwise UnsupportedOperationException
         final CompletableFuture<T>[] cfArray = f_toNonMinCfArray(cfs);
-        return orTimeout(CompletableFuture.allOf(cfArray), timeout, unit)
+        return orTimeout(CompletableFuture.allOf(cfArray), timeout, unit, AsyncPoolHolder.ASYNC_POOL)
                 .handle((unused, ex) -> arrayList(MGetSuccessNow0(valueIfNotSuccess, cfArray)));
     }
 
@@ -676,7 +676,7 @@ private static <T> CompletableFuture<T> mostTupleOfSuccess0(
         // MUST be *Non-Minimal* CF instances in order to read results(`getSuccessNow`),
         // otherwise UnsupportedOperationException
         final CompletableFuture<Object>[] cfArray = f_toNonMinCfArray(css);
-        return orTimeout(CompletableFuture.allOf(cfArray), timeout, unit)
+        return orTimeout(CompletableFuture.allOf(cfArray), timeout, unit, AsyncPoolHolder.ASYNC_POOL)
                 .handle((unused, ex) -> tupleOf0(MGetSuccessNow0(null, cfArray)));
     }