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 |
|
|
4835 |
|
}} |
4836 |
|
|
4837 |
|
/** |
4838 |
< |
* defult exceptionallyCompose result completes normally after normal |
4838 |
> |
* default exceptionallyCompose result completes normally after normal |
4839 |
|
* completion of source |
4840 |
|
*/ |
4841 |
|
public void testDefaultExceptionallyCompose_normalCompletion() { |
4902 |
|
}} |
4903 |
|
|
4904 |
|
/** |
4905 |
< |
* defult exceptionallyComposeAsync result completes normally after normal |
4905 |
> |
* default exceptionallyComposeAsync result completes normally after normal |
4906 |
|
* completion of source |
4907 |
|
*/ |
4908 |
|
public void testDefaultExceptionallyComposeAsync_normalCompletion() { |
4970 |
|
|
4971 |
|
|
4972 |
|
/** |
4973 |
< |
* defult exceptionallyComposeAsync result completes normally after normal |
4973 |
> |
* default exceptionallyComposeAsync result completes normally after normal |
4974 |
|
* completion of source |
4975 |
|
*/ |
4976 |
|
public void testDefaultExceptionallyComposeAsyncExecutor_normalCompletion() { |
5037 |
|
}} |
5038 |
|
|
5039 |
|
} |
5044 |
– |
|