fix: wrong exector for Cffu.thenTupleM* methods

foldright · Jun 24, 2024 · e834f98 · e834f98
1 parent 1b0cd8b
commit e834f98
Showing 1 changed file with 8 additions and 8 deletions.
diff --git a/cffu-core/src/main/java/io/foldright/cffu/Cffu.java b/cffu-core/src/main/java/io/foldright/cffu/Cffu.java
@@ -230,7 +230,7 @@ public Cffu<Void> thenRunAsync(Runnable action, Executor executor) {
      */
     public <U1, U2> Cffu<Tuple2<U1, U2>> thenTupleMApplyFastFailAsync(
             Function<? super T, ? extends U1> fn1, Function<? super T, ? extends U2> fn2) {
-        return reset0(CompletableFutureUtils.thenTupleMApplyFastFailAsync(cf, fn1, fn2));
+        return reset0(CompletableFutureUtils.thenTupleMApplyFastFailAsync(cf, fac.defaultExecutor(), fn1, fn2));
     }
 
     /**
@@ -248,7 +248,7 @@ public <U1, U2> Cffu<Tuple2<U1, U2>> thenTupleMApplyFastFailAsync(
     public <U1, U2, U3> Cffu<Tuple3<U1, U2, U3>> thenTupleMApplyFastFailAsync(
             Function<? super T, ? extends U1> fn1, Function<? super T, ? extends U2> fn2,
             Function<? super T, ? extends U3> fn3) {
-        return reset0(CompletableFutureUtils.thenTupleMApplyFastFailAsync(cf, fn1, fn2, fn3));
+        return reset0(CompletableFutureUtils.thenTupleMApplyFastFailAsync(cf, fac.defaultExecutor(), fn1, fn2, fn3));
     }
 
     /**
@@ -266,7 +266,7 @@ public <U1, U2, U3> Cffu<Tuple3<U1, U2, U3>> thenTupleMApplyFastFailAsync(
     public <U1, U2, U3, U4> Cffu<Tuple4<U1, U2, U3, U4>> thenTupleMApplyFastFailAsync(
             Function<? super T, ? extends U1> fn1, Function<? super T, ? extends U2> fn2,
             Function<? super T, ? extends U3> fn3, Function<? super T, ? extends U4> fn4) {
-        return reset0(CompletableFutureUtils.thenTupleMApplyFastFailAsync(cf, fn1, fn2, fn3, fn4));
+        return reset0(CompletableFutureUtils.thenTupleMApplyFastFailAsync(cf, fac.defaultExecutor(), fn1, fn2, fn3, fn4));
     }
 
     /**
@@ -285,7 +285,7 @@ public <U1, U2, U3, U4, U5> Cffu<Tuple5<U1, U2, U3, U4, U5>> thenTupleMApplyFast
             Function<? super T, ? extends U1> fn1, Function<? super T, ? extends U2> fn2,
             Function<? super T, ? extends U3> fn3, Function<? super T, ? extends U4> fn4,
             Function<? super T, ? extends U5> fn5) {
-        return reset0(CompletableFutureUtils.thenTupleMApplyFastFailAsync(cf, fn1, fn2, fn3, fn4, fn5));
+        return reset0(CompletableFutureUtils.thenTupleMApplyFastFailAsync(cf, fac.defaultExecutor(), fn1, fn2, fn3, fn4, fn5));
     }
 
     /**
@@ -299,7 +299,7 @@ public <U1, U2, U3, U4, U5> Cffu<Tuple5<U1, U2, U3, U4, U5>> thenTupleMApplyFast
      */
     public <U1, U2> Cffu<Tuple2<U1, U2>> thenTupleMApplyAsync(
             Function<? super T, ? extends U1> fn1, Function<? super T, ? extends U2> fn2) {
-        return reset0(CompletableFutureUtils.thenTupleMApplyAsync(cf, fn1, fn2));
+        return reset0(CompletableFutureUtils.thenTupleMApplyAsync(cf, fac.defaultExecutor(), fn1, fn2));
     }
 
     /**
@@ -314,7 +314,7 @@ public <U1, U2> Cffu<Tuple2<U1, U2>> thenTupleMApplyAsync(
     public <U1, U2, U3> Cffu<Tuple3<U1, U2, U3>> thenTupleMApplyAsync(
             Function<? super T, ? extends U1> fn1, Function<? super T, ? extends U2> fn2,
             Function<? super T, ? extends U3> fn3) {
-        return reset0(CompletableFutureUtils.thenTupleMApplyAsync(cf, fn1, fn2, fn3));
+        return reset0(CompletableFutureUtils.thenTupleMApplyAsync(cf, fac.defaultExecutor(), fn1, fn2, fn3));
     }
 
     /**
@@ -329,7 +329,7 @@ public <U1, U2, U3> Cffu<Tuple3<U1, U2, U3>> thenTupleMApplyAsync(
     public <U1, U2, U3, U4> Cffu<Tuple4<U1, U2, U3, U4>> thenTupleMApplyAsync(
             Function<? super T, ? extends U1> fn1, Function<? super T, ? extends U2> fn2,
             Function<? super T, ? extends U3> fn3, Function<? super T, ? extends U4> fn4) {
-        return reset0(CompletableFutureUtils.thenTupleMApplyAsync(cf, fn1, fn2, fn3, fn4));
+        return reset0(CompletableFutureUtils.thenTupleMApplyAsync(cf, fac.defaultExecutor(), fn1, fn2, fn3, fn4));
     }
 
     /**
@@ -345,7 +345,7 @@ public <U1, U2, U3, U4, U5> Cffu<Tuple5<U1, U2, U3, U4, U5>> thenTupleMApplyAsyn
             Function<? super T, ? extends U1> fn1, Function<? super T, ? extends U2> fn2,
             Function<? super T, ? extends U3> fn3, Function<? super T, ? extends U4> fn4,
             Function<? super T, ? extends U5> fn5) {
-        return reset0(CompletableFutureUtils.thenTupleMApplyAsync(cf, fn1, fn2, fn3, fn4, fn5));
+        return reset0(CompletableFutureUtils.thenTupleMApplyAsync(cf, fac.defaultExecutor(), fn1, fn2, fn3, fn4, fn5));
     }
 
     // endregion