| 1010 |
|
/** |
| 1011 |
|
* If a whenComplete action throws an exception when triggered by |
| 1012 |
|
* a source completion that also throws an exception, the source |
| 1013 |
< |
* exception takes precedence. |
| 1013 |
> |
* exception takes precedence (unlike handle) |
| 1014 |
|
*/ |
| 1015 |
< |
public void testWhenComplete_actionFailedSourceFailed() { |
| 1015 |
> |
public void testWhenComplete_sourceFailedActionFailed() { |
| 1016 |
|
for (boolean createIncomplete : new boolean[] { true, false }) |
| 1017 |
|
for (ExecutionMode m : ExecutionMode.values()) |
| 1018 |
|
{ |
| 1125 |
|
}} |
| 1126 |
|
|
| 1127 |
|
/** |
| 1128 |
< |
* handle result completes exceptionally if action does |
| 1128 |
> |
* If a "handle action" throws an exception when triggered by |
| 1129 |
> |
* a normal completion, it completes exceptionally |
| 1130 |
|
*/ |
| 1131 |
< |
public void testHandle_sourceFailedActionFailed() { |
| 1131 |
> |
public void testHandle_sourceCompletedNormallyActionFailed() { |
| 1132 |
|
for (ExecutionMode m : ExecutionMode.values()) |
| 1133 |
|
for (boolean createIncomplete : new boolean[] { true, false }) |
| 1134 |
+ |
for (Integer v1 : new Integer[] { 1, null }) |
| 1135 |
|
{ |
| 1136 |
|
final CompletableFuture<Integer> f = new CompletableFuture<>(); |
| 1137 |
|
final AtomicInteger a = new AtomicInteger(0); |
| 1138 |
< |
final CFException ex1 = new CFException(); |
| 1139 |
< |
final CFException ex2 = new CFException(); |
| 1138 |
< |
if (!createIncomplete) f.completeExceptionally(ex1); |
| 1138 |
> |
final CFException ex = new CFException(); |
| 1139 |
> |
if (!createIncomplete) assertTrue(f.complete(v1)); |
| 1140 |
|
final CompletableFuture<Integer> g = m.handle |
| 1141 |
|
(f, |
| 1142 |
|
(Integer x, Throwable t) -> { |
| 1143 |
|
m.checkExecutionMode(); |
| 1144 |
< |
threadAssertNull(x); |
| 1145 |
< |
threadAssertSame(ex1, t); |
| 1144 |
> |
threadAssertSame(x, v1); |
| 1145 |
> |
threadAssertNull(t); |
| 1146 |
|
a.getAndIncrement(); |
| 1147 |
< |
throw ex2; |
| 1147 |
> |
throw ex; |
| 1148 |
|
}); |
| 1149 |
< |
if (createIncomplete) f.completeExceptionally(ex1); |
| 1149 |
> |
if (createIncomplete) assertTrue(f.complete(v1)); |
| 1150 |
|
|
| 1151 |
< |
checkCompletedWithWrappedException(g, ex2); |
| 1152 |
< |
checkCompletedExceptionally(f, ex1); |
| 1151 |
> |
checkCompletedWithWrappedException(g, ex); |
| 1152 |
> |
checkCompletedNormally(f, v1); |
| 1153 |
|
assertEquals(1, a.get()); |
| 1154 |
|
}} |
| 1155 |
|
|
| 1156 |
|
/** |
| 1157 |
|
* If a "handle action" throws an exception when triggered by |
| 1158 |
< |
* a normal completion, it completes exceptionally |
| 1158 |
> |
* a source completion that also throws an exception, the action |
| 1159 |
> |
* exception takes precedence (unlike whenComplete) |
| 1160 |
|
*/ |
| 1161 |
< |
public void testHandle_sourceCompletedNormallyActionFailed() { |
| 1160 |
< |
for (ExecutionMode m : ExecutionMode.values()) |
| 1161 |
> |
public void testHandle_sourceFailedActionFailed() { |
| 1162 |
|
for (boolean createIncomplete : new boolean[] { true, false }) |
| 1163 |
< |
for (Integer v1 : new Integer[] { 1, null }) |
| 1163 |
> |
for (ExecutionMode m : ExecutionMode.values()) |
| 1164 |
|
{ |
| 1164 |
– |
final CompletableFuture<Integer> f = new CompletableFuture<>(); |
| 1165 |
|
final AtomicInteger a = new AtomicInteger(0); |
| 1166 |
< |
final CFException ex = new CFException(); |
| 1167 |
< |
if (!createIncomplete) assertTrue(f.complete(v1)); |
| 1166 |
> |
final CFException ex1 = new CFException(); |
| 1167 |
> |
final CFException ex2 = new CFException(); |
| 1168 |
> |
final CompletableFuture<Integer> f = new CompletableFuture<>(); |
| 1169 |
> |
|
| 1170 |
> |
if (!createIncomplete) f.completeExceptionally(ex1); |
| 1171 |
|
final CompletableFuture<Integer> g = m.handle |
| 1172 |
|
(f, |
| 1173 |
|
(Integer x, Throwable t) -> { |
| 1174 |
|
m.checkExecutionMode(); |
| 1175 |
< |
threadAssertSame(x, v1); |
| 1176 |
< |
threadAssertNull(t); |
| 1175 |
> |
threadAssertNull(x); |
| 1176 |
> |
threadAssertSame(ex1, t); |
| 1177 |
|
a.getAndIncrement(); |
| 1178 |
< |
throw ex; |
| 1178 |
> |
throw ex2; |
| 1179 |
|
}); |
| 1180 |
< |
if (createIncomplete) assertTrue(f.complete(v1)); |
| 1180 |
> |
if (createIncomplete) f.completeExceptionally(ex1); |
| 1181 |
|
|
| 1182 |
< |
checkCompletedWithWrappedException(g, ex); |
| 1183 |
< |
checkCompletedNormally(f, v1); |
| 1182 |
> |
checkCompletedWithWrappedException(g, ex2); |
| 1183 |
> |
checkCompletedExceptionally(f, ex1); |
| 1184 |
|
assertEquals(1, a.get()); |
| 1185 |
|
}} |
| 1186 |
|
|
