3156 |
|
|
3157 |
|
dependentFactories.add((y) -> m.thenCompose(y, new CompletableFutureInc(m))); |
3158 |
|
|
3159 |
+ |
dependentFactories.add((y) -> CompletableFuture.allOf(new CompletableFuture<?>[] {y, v42})); |
3160 |
+ |
dependentFactories.add((y) -> CompletableFuture.anyOf(new CompletableFuture<?>[] {y, incomplete})); |
3161 |
+ |
|
3162 |
|
for (Function<CompletableFuture<Integer>, CompletableFuture<?>> |
3163 |
|
dependentFactory : dependentFactories) { |
3164 |
|
CompletableFuture<Integer> f = new CompletableFuture<>(); |
3208 |
|
} |
3209 |
|
}} |
3210 |
|
|
3208 |
– |
// public void testRunAfterEither_resultDeterminedAtTimeOfCreation() { |
3209 |
– |
// for (ExecutionMode m : ExecutionMode.values()) |
3210 |
– |
// for (boolean mayInterruptIfRunning : new boolean[] { true, false }) |
3211 |
– |
// for (Integer v1 : new Integer[] { 1, null }) |
3212 |
– |
// { |
3213 |
– |
// final CompletableFuture<Integer> f = new CompletableFuture<>(); |
3214 |
– |
// final CompletableFuture<Integer> g = new CompletableFuture<>(); |
3215 |
– |
// final Noop[] rs = new Noop[2]; |
3216 |
– |
// for (int i = 0; i < rs.length; i++) rs[i] = new Noop(m); |
3217 |
– |
// f.complete(v1); |
3218 |
– |
// final CompletableFuture<Void> h0 = m.runAfterEither(f, g, rs[0]); |
3219 |
– |
// final CompletableFuture<Void> h1 = m.runAfterEither(g, f, rs[1]); |
3220 |
– |
// assertTrue(g.cancel(mayInterruptIfRunning)); |
3221 |
– |
// checkCompletedNormally(h0, null); |
3222 |
– |
// checkCompletedNormally(h1, null); |
3223 |
– |
// for (Noop r : rs) r.assertInvoked(); |
3224 |
– |
// }} |
3225 |
– |
|
3211 |
|
} |