1171 |
|
|
1172 |
|
checkCompletedNormally(g, inc(v1)); |
1173 |
|
checkCompletedNormally(f, v1); |
1174 |
< |
r.assertInvoked(); |
1174 |
> |
r.assertValue(inc(v1)); |
1175 |
|
}} |
1176 |
|
|
1177 |
|
/** |
1356 |
|
checkCompletedNormally(h, subtract(v1, v2)); |
1357 |
|
checkCompletedNormally(f, v1); |
1358 |
|
checkCompletedNormally(g, v2); |
1359 |
< |
r.assertInvoked(); |
1359 |
> |
r.assertValue(subtract(v1, v2)); |
1360 |
|
}} |
1361 |
|
|
1362 |
|
/** |
2531 |
|
|
2532 |
|
checkCompletedNormally(g, inc(v1)); |
2533 |
|
checkCompletedNormally(f, v1); |
2534 |
< |
r.assertInvoked(); |
2534 |
> |
r.assertValue(v1); |
2535 |
|
}} |
2536 |
|
|
2537 |
|
/** |
2821 |
|
final CompletableFuture<Integer> g = m.whenComplete |
2822 |
|
(f, |
2823 |
|
(Integer x, Throwable t) -> { |
2824 |
+ |
m.checkExecutionMode(); |
2825 |
|
threadAssertSame(x, v1); |
2826 |
|
threadAssertNull(t); |
2827 |
|
a.getAndIncrement(); |
2849 |
|
final CompletableFuture<Integer> g = m.whenComplete |
2850 |
|
(f, |
2851 |
|
(Integer x, Throwable t) -> { |
2852 |
+ |
m.checkExecutionMode(); |
2853 |
|
threadAssertNull(x); |
2854 |
|
threadAssertSame(t, ex); |
2855 |
|
a.getAndIncrement(); |
2875 |
|
final CompletableFuture<Integer> g = m.whenComplete |
2876 |
|
(f, |
2877 |
|
(Integer x, Throwable t) -> { |
2878 |
+ |
m.checkExecutionMode(); |
2879 |
|
threadAssertNull(x); |
2880 |
|
threadAssertTrue(t instanceof CancellationException); |
2881 |
|
a.getAndIncrement(); |
2882 |
|
}); |
2883 |
|
if (createIncomplete) assertTrue(f.cancel(mayInterruptIfRunning)); |
2884 |
|
|
2882 |
– |
//try { g.join(); } catch (Throwable t) { throw new Error(t); } |
2885 |
|
checkCompletedWithWrappedCancellationException(g); |
2886 |
|
checkCancelled(f); |
2887 |
|
assertEquals(1, a.get()); |
2903 |
|
final CompletableFuture<Integer> g = m.whenComplete |
2904 |
|
(f, |
2905 |
|
(Integer x, Throwable t) -> { |
2906 |
+ |
m.checkExecutionMode(); |
2907 |
|
threadAssertSame(x, v1); |
2908 |
|
threadAssertNull(t); |
2909 |
|
a.getAndIncrement(); |
2934 |
|
final CompletableFuture<Integer> g = m.whenComplete |
2935 |
|
(f, |
2936 |
|
(Integer x, Throwable t) -> { |
2937 |
+ |
m.checkExecutionMode(); |
2938 |
|
threadAssertSame(t, ex1); |
2939 |
|
threadAssertNull(x); |
2940 |
|
a.getAndIncrement(); |