837 |
|
if (!createIncomplete) assertTrue(f.complete(v1)); |
838 |
|
final CompletableFuture<Integer> g = f.exceptionally |
839 |
|
((Throwable t) -> { |
840 |
– |
// Should not be called |
840 |
|
a.getAndIncrement(); |
841 |
< |
throw new AssertionError(); |
841 |
> |
threadFail("should not be called"); |
842 |
> |
return null; // unreached |
843 |
|
}); |
844 |
|
if (createIncomplete) assertTrue(f.complete(v1)); |
845 |
|
|
898 |
|
* whenComplete action executes on normal completion, propagating |
899 |
|
* source result. |
900 |
|
*/ |
901 |
< |
public void testWhenComplete_normalCompletion1() { |
901 |
> |
public void testWhenComplete_normalCompletion() { |
902 |
|
for (ExecutionMode m : ExecutionMode.values()) |
903 |
|
for (boolean createIncomplete : new boolean[] { true, false }) |
904 |
|
for (Integer v1 : new Integer[] { 1, null }) |
3708 |
|
(method) -> (method.getModifiers() & Modifier.STATIC) == 0; |
3709 |
|
List<Method> minimalMethods = |
3710 |
|
Stream.of(Object.class, CompletionStage.class) |
3711 |
< |
.map((klazz) -> Stream.of(klazz.getMethods())) |
3712 |
< |
.reduce(Stream::concat) |
3713 |
< |
.orElseGet(Stream::empty) |
3711 |
> |
.flatMap((klazz) -> Stream.of(klazz.getMethods())) |
3712 |
|
.filter(isNotStatic) |
3713 |
|
.collect(Collectors.toList()); |
3714 |
|
// Methods from CompletableFuture permitted NOT to throw UOE |