Skip to content

Commit 1db4177

Browse files
committed
Fix executor used with AbstractCompletableTask.whenCompleteAsync
1 parent 970e334 commit 1db4177

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -237,7 +237,7 @@ public Promise<T> exceptionally(Function<Throwable, ? extends T> fn) {
237237

238238
@Override
239239
public Promise<T> whenCompleteAsync(BiConsumer<? super T, ? super Throwable> action, Executor executor) {
240-
AbstractCompletableTask<T> nextStage = internalCreateCompletionStage(getDefaultExecutor());
240+
AbstractCompletableTask<T> nextStage = internalCreateCompletionStage(executor);
241241
addCallbacks(
242242
nextStage,
243243
result -> {

0 commit comments

Comments
 (0)