Skip to content

Commit daa1a89

Browse files
committed
Inline single-use method in AbstractCompletableTask
1 parent 5756b4a commit daa1a89

File tree

1 file changed

+1
-8
lines changed

1 file changed

+1
-8
lines changed

src/main/java/net/tascalate/concurrent/AbstractCompletableTask.java

Lines changed: 1 addition & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -158,7 +158,7 @@ protected void setException(Throwable t) {
158158
@Override
159159
public <U> Promise<U> thenApplyAsync(Function<? super T, ? extends U> fn, Executor executor) {
160160
AbstractCompletableTask<U> nextStage = internalCreateCompletionStage(executor);
161-
addCallbacks(nextStage, fn, executor);
161+
addCallbacks(nextStage, fn, AbstractCompletableTask::forwardException, executor);
162162
return nextStage;
163163
}
164164

@@ -468,13 +468,6 @@ private static ExecutionException rewrapExecutionException(ExecutionException ex
468468
return wrapExecutionException( unwrapCompletionException(unwrapExecutionException(ex)) );
469469
}
470470

471-
private <U> void addCallbacks(AbstractCompletableTask<U> targetStage,
472-
Function<? super T, ? extends U> successCallback,
473-
Executor executor) {
474-
475-
addCallbacks(targetStage, successCallback, AbstractCompletableTask::forwardException, executor);
476-
}
477-
478471
private <U> void addCallbacks(AbstractCompletableTask<U> targetStage,
479472
Function<? super T, ? extends U> successCallback,
480473
Function<Throwable, ? extends U> failureCallback,

0 commit comments

Comments
 (0)