Skip to content

Commit

Permalink
WIP
Browse files Browse the repository at this point in the history
  • Loading branch information
@oldratlee
oldratlee committed Jun 22, 2024
1 parent 3919dc9 commit 4df5089
Show file tree
Hide file tree
Showing 4 changed files with 70 additions and 70 deletions.
40 changes: 20 additions & 20 deletions cffu-core/src/main/java/io/foldright/cffu/CffuFactory.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -683,15 +683,15 @@ public <T1, T2, T3, T4, T5> Cffu<Tuple5<T1, T2, T3, T4, T5>> mostTupleOfSuccess(
* (with the given stage's result as the argument to the given functions)
* in the <strong>same order</strong> of the given Functions arguments.
* <p>
* This method is the same as {@link #allTupleOfThenMApplyAsync(CompletionStage, Function, Function)}
* This method is the same as {@link #thenTupleMApplyAsync(CompletionStage, Function, Function)}
* except for the fast-fail behavior.
*
* @return the new Cffu
*/
@Contract(pure = true)
public <T, U1, U2> Cffu<Tuple2<U1, U2>> allTupleOfThenMApplyFastFailAsync(
public <T, U1, U2> Cffu<Tuple2<U1, U2>> thenTupleMApplyFastFailAsync(
CompletionStage<? extends T> cf, Function<? super T, ? extends U1> fn1, Function<? super T, ? extends U2> fn2) {
return create(CompletableFutureUtils.allTupleOfThenMApplyFastFailAsync(cf, fn1, fn2));
return create(CompletableFutureUtils.thenTupleMApplyFastFailAsync(cf, fn1, fn2));
}

/**
Expand All @@ -701,16 +701,16 @@ public <T, U1, U2> Cffu<Tuple2<U1, U2>> allTupleOfThenMApplyFastFailAsync(
* (with the given stage's result as the argument to the given functions)
* in the <strong>same order</strong> of the given Functions arguments.
* <p>
* This method is the same as {@link #allTupleOfThenMApplyAsync(CompletionStage, Function, Function, Function)}
* This method is the same as {@link #thenTupleMApplyAsync(CompletionStage, Function, Function, Function)}
* except for the fast-fail behavior.
*
* @return the new Cffu
*/
@Contract(pure = true)
public <T, U1, U2, U3> Cffu<Tuple3<U1, U2, U3>> allTupleOfThenMApplyFastFailAsync(
public <T, U1, U2, U3> Cffu<Tuple3<U1, U2, U3>> thenTupleMApplyFastFailAsync(
CompletionStage<? extends T> cf, Function<? super T, ? extends U1> fn1,
Function<? super T, ? extends U2> fn2, Function<? super T, ? extends U3> fn3) {
return create(CompletableFutureUtils.allTupleOfThenMApplyFastFailAsync(cf, fn1, fn2, fn3));
return create(CompletableFutureUtils.thenTupleMApplyFastFailAsync(cf, fn1, fn2, fn3));
}

/**
Expand All @@ -720,17 +720,17 @@ public <T, U1, U2, U3> Cffu<Tuple3<U1, U2, U3>> allTupleOfThenMApplyFastFailAsyn
* (with the given stage's result as the argument to the given functions)
* in the <strong>same order</strong> of the given Functions arguments.
* <p>
* This method is the same as {@link #allTupleOfThenMApplyAsync(CompletionStage, Function, Function, Function, Function)}
* This method is the same as {@link #thenTupleMApplyAsync(CompletionStage, Function, Function, Function, Function)}
* except for the fast-fail behavior.
*
* @return the new Cffu
*/
@Contract(pure = true)
public <T, U1, U2, U3, U4> Cffu<Tuple4<U1, U2, U3, U4>> allTupleOfThenMApplyFastFailAsync(
public <T, U1, U2, U3, U4> Cffu<Tuple4<U1, U2, U3, U4>> thenTupleMApplyFastFailAsync(
CompletionStage<? extends T> cf,
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 create(CompletableFutureUtils.allTupleOfThenMApplyFastFailAsync(cf, fn1, fn2, fn3, fn4));
return create(CompletableFutureUtils.thenTupleMApplyFastFailAsync(cf, fn1, fn2, fn3, fn4));
}

/**
Expand All @@ -740,17 +740,17 @@ public <T, U1, U2, U3, U4> Cffu<Tuple4<U1, U2, U3, U4>> allTupleOfThenMApplyFast
* (with the given stage's result as the argument to the given functions)
* in the <strong>same order</strong> of the given Functions arguments.
* <p>
* This method is the same as {@link #allTupleOfThenMApplyAsync(CompletionStage, Function, Function, Function, Function, Function)}
* This method is the same as {@link #thenTupleMApplyAsync(CompletionStage, Function, Function, Function, Function, Function)}
* except for the fast-fail behavior.
*
* @return the new Cffu
*/
@Contract(pure = true)
public <T, U1, U2, U3, U4, U5> Cffu<Tuple5<U1, U2, U3, U4, U5>> allTupleOfThenMApplyFastFailAsync(
public <T, U1, U2, U3, U4, U5> Cffu<Tuple5<U1, U2, U3, U4, U5>> thenTupleMApplyFastFailAsync(
CompletionStage<? extends T> cf, 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 create(CompletableFutureUtils.allTupleOfThenMApplyFastFailAsync(cf, fn1, fn2, fn3, fn4, fn5));
return create(CompletableFutureUtils.thenTupleMApplyFastFailAsync(cf, fn1, fn2, fn3, fn4, fn5));
}

/**
Expand All @@ -763,10 +763,10 @@ public <T, U1, U2, U3, U4, U5> Cffu<Tuple5<U1, U2, U3, U4, U5>> allTupleOfThenMA
* @return the new Cffu
*/
@Contract(pure = true)
public <T, U1, U2> Cffu<Tuple2<U1, U2>> allTupleOfThenMApplyAsync(
public <T, U1, U2> Cffu<Tuple2<U1, U2>> thenTupleMApplyAsync(
CompletionStage<? extends T> cf,
Function<? super T, ? extends U1> fn1, Function<? super T, ? extends U2> fn2) {
return create(CompletableFutureUtils.allTupleOfThenMApplyAsync(cf, fn1, fn2));
return create(CompletableFutureUtils.thenTupleMApplyAsync(cf, fn1, fn2));
}

/**
Expand All @@ -779,10 +779,10 @@ public <T, U1, U2> Cffu<Tuple2<U1, U2>> allTupleOfThenMApplyAsync(
* @return the new Cffu
*/
@Contract(pure = true)
public <T, U1, U2, U3> Cffu<Tuple3<U1, U2, U3>> allTupleOfThenMApplyAsync(
public <T, U1, U2, U3> Cffu<Tuple3<U1, U2, U3>> thenTupleMApplyAsync(
CompletionStage<? extends T> cf, Function<? super T, ? extends U1> fn1,
Function<? super T, ? extends U2> fn2, Function<? super T, ? extends U3> fn3) {
return create(CompletableFutureUtils.allTupleOfThenMApplyAsync(cf, fn1, fn2, fn3));
return create(CompletableFutureUtils.thenTupleMApplyAsync(cf, fn1, fn2, fn3));
}

/**
Expand All @@ -795,11 +795,11 @@ public <T, U1, U2, U3> Cffu<Tuple3<U1, U2, U3>> allTupleOfThenMApplyAsync(
* @return the new Cffu
*/
@Contract(pure = true)
public <T, U1, U2, U3, U4> Cffu<Tuple4<U1, U2, U3, U4>> allTupleOfThenMApplyAsync(
public <T, U1, U2, U3, U4> Cffu<Tuple4<U1, U2, U3, U4>> thenTupleMApplyAsync(
CompletionStage<? extends T> cf,
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 create(CompletableFutureUtils.allTupleOfThenMApplyAsync(cf, fn1, fn2, fn3, fn4));
return create(CompletableFutureUtils.thenTupleMApplyAsync(cf, fn1, fn2, fn3, fn4));
}

/**
Expand All @@ -812,11 +812,11 @@ public <T, U1, U2, U3, U4> Cffu<Tuple4<U1, U2, U3, U4>> allTupleOfThenMApplyAsyn
* @return the new Cffu
*/
@Contract(pure = true)
public <T, U1, U2, U3, U4, U5> Cffu<Tuple5<U1, U2, U3, U4, U5>> allTupleOfThenMApplyAsync(
public <T, U1, U2, U3, U4, U5> Cffu<Tuple5<U1, U2, U3, U4, U5>> thenTupleMApplyAsync(
CompletionStage<? extends T> cf, 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 create(CompletableFutureUtils.allTupleOfThenMApplyAsync(cf, fn1, fn2, fn3, fn4, fn5));
return create(CompletableFutureUtils.thenTupleMApplyAsync(cf, fn1, fn2, fn3, fn4, fn5));
}

// endregion
Expand Down
Loading

0 comments on commit 4df5089

Please sign in to comment.