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(); |