3390 |
|
* completedStage returns a completed CompletionStage |
3391 |
|
*/ |
3392 |
|
public void testCompletedStage() { |
3393 |
< |
AtomicInteger x = new AtomicInteger(); |
3393 |
> |
AtomicInteger x = new AtomicInteger(0); |
3394 |
|
AtomicReference<Throwable> r = new AtomicReference<Throwable>(); |
3395 |
|
CompletionStage<Integer> f = CompletableFuture.completedStage(1); |
3396 |
|
f.whenComplete((v, e) -> {if (e != null) r.set(e); else x.set(v);}); |
3419 |
|
public void testFailedFuture() { |
3420 |
|
CFException ex = new CFException(); |
3421 |
|
CompletableFuture<Integer> f = CompletableFuture.failedFuture(ex); |
3422 |
< |
checkCompletedExceptionallyWithRootCause(f, ex); |
3422 |
> |
checkCompletedExceptionally(f, ex); |
3423 |
|
} |
3424 |
|
|
3425 |
|
/** |
3468 |
|
public void testMinimalCompletionStage() { |
3469 |
|
CompletableFuture<Integer> f = new CompletableFuture<>(); |
3470 |
|
CompletionStage<Integer> g = f.minimalCompletionStage(); |
3471 |
< |
AtomicInteger x = new AtomicInteger(); |
3471 |
> |
AtomicInteger x = new AtomicInteger(0); |
3472 |
|
AtomicReference<Throwable> r = new AtomicReference<Throwable>(); |
3473 |
|
checkIncomplete(f); |
3474 |
|
g.whenComplete((v, e) -> {if (e != null) r.set(e); else x.set(v);}); |
3485 |
|
public void testMinimalCompletionStage2() { |
3486 |
|
CompletableFuture<Integer> f = new CompletableFuture<>(); |
3487 |
|
CompletionStage<Integer> g = f.minimalCompletionStage(); |
3488 |
< |
AtomicInteger x = new AtomicInteger(); |
3488 |
> |
AtomicInteger x = new AtomicInteger(0); |
3489 |
|
AtomicReference<Throwable> r = new AtomicReference<Throwable>(); |
3490 |
|
g.whenComplete((v, e) -> {if (e != null) r.set(e); else x.set(v);}); |
3491 |
|
checkIncomplete(f); |
3503 |
|
public void testFailedStage() { |
3504 |
|
CFException ex = new CFException(); |
3505 |
|
CompletionStage<Integer> f = CompletableFuture.failedStage(ex); |
3506 |
< |
AtomicInteger x = new AtomicInteger(); |
3506 |
> |
AtomicInteger x = new AtomicInteger(0); |
3507 |
|
AtomicReference<Throwable> r = new AtomicReference<Throwable>(); |
3508 |
|
f.whenComplete((v, e) -> {if (e != null) r.set(e); else x.set(v);}); |
3509 |
|
assertEquals(x.get(), 0); |
3510 |
< |
assertEquals(r.get().getCause(), ex); |
3510 |
> |
assertEquals(r.get(), ex); |
3511 |
|
} |
3512 |
|
|
3513 |
|
/** |