551 |
|
public CompletableFuture<Integer> apply(Integer x) { |
552 |
|
invoked(); |
553 |
|
value = x; |
554 |
< |
CompletableFuture<Integer> f = new CompletableFuture<>(); |
555 |
< |
assertTrue(f.complete(inc(x))); |
556 |
< |
return f; |
554 |
> |
return CompletableFuture.completedFuture(inc(x)); |
555 |
|
} |
556 |
|
} |
557 |
|
|
572 |
|
ExceptionalCompletableFutureFunction(ExecutionMode m) { super(m); } |
573 |
|
public CompletionStage<Integer> apply(Throwable x) { |
574 |
|
invoked(); |
575 |
< |
CompletableFuture<Integer> d = new CompletableFuture<Integer>(); |
578 |
< |
d.complete(value); |
579 |
< |
return d; |
575 |
> |
return CompletableFuture.completedFuture(value); |
576 |
|
} |
577 |
|
} |
578 |
|
|
4783 |
|
* default-implemented exceptionallyAsync action completes with |
4784 |
|
* function value on source exception |
4785 |
|
*/ |
4786 |
< |
public void testDefaulExceptionallyAsync_exceptionalCompletion() { |
4786 |
> |
public void testDefaultExceptionallyAsync_exceptionalCompletion() { |
4787 |
|
for (boolean createIncomplete : new boolean[] { true, false }) |
4788 |
|
for (Integer v1 : new Integer[] { 1, null }) |
4789 |
|
{ |
4810 |
|
* throws an exception, it completes exceptionally with that |
4811 |
|
* exception |
4812 |
|
*/ |
4813 |
< |
public void testDefaulExceptionallyAsync_exceptionalCompletionActionFailed() { |
4813 |
> |
public void testDefaultExceptionallyAsync_exceptionalCompletionActionFailed() { |
4814 |
|
for (boolean createIncomplete : new boolean[] { true, false }) |
4815 |
|
{ |
4816 |
|
final AtomicInteger a = new AtomicInteger(0); |