Lines Matching refs:futures
20 import static com.google.common.util.concurrent.Futures.allAsList;
21 import static com.google.common.util.concurrent.Futures.get;
22 import static com.google.common.util.concurrent.Futures.getUnchecked;
23 import static com.google.common.util.concurrent.Futures.immediateFailedFuture;
24 import static com.google.common.util.concurrent.Futures.immediateFuture;
25 import static com.google.common.util.concurrent.Futures.successfulAsList;
72 * Unit tests for {@link Futures}.
74 * TODO: Add tests for other Futures methods
80 "com.google.common.util.concurrent.Futures$CombinedFuture");
108 ListenableFuture<String> future = Futures.immediateFuture(DATA1);
115 ListenableFuture<String> future1 = Futures.immediateFuture(DATA1);
116 ListenableFuture<String> future2 = Futures.immediateFuture(DATA2);
126 Futures.immediateFailedFuture(exception);
140 Futures.immediateFailedFuture(exception);
154 Futures.immediateCancelledFuture();
161 CheckedFuture<String, MyException> future = Futures.immediateCheckedFuture(
170 CheckedFuture<String, MyException> future1 = Futures.immediateCheckedFuture(
172 CheckedFuture<String, MyException> future2 = Futures.immediateCheckedFuture(
185 Futures.immediateFailedCheckedFuture(exception);
211 ListenableFuture<?> nullFuture = Futures.immediateFuture(null);
213 Futures.transform(nullFuture, Functions.constant(null));
218 ListenableFuture<FooChild> future = Futures.immediateFuture(null);
225 Bar bar = Futures.transform(future, function).get();
236 assertTrue(Futures.transform(input, function).cancel(false));
248 assertTrue(Futures.transform(input, function).cancel(true));
254 ListenableFuture<Foo> immediate = Futures.immediateFuture(new Foo());
261 assertTrue(Futures.transform(immediate, function).cancel(false));
268 ListenableFuture<Foo> immediate = Futures.immediateFuture(new Foo());
275 assertTrue(Futures.transform(immediate, function).cancel(true));
300 ListenableFuture<Integer> immediateFuture = Futures.immediateFuture(4);
301 Future<Integer> transformedFuture = Futures.transform(immediateFuture, adder);
321 assertEquals(8, Futures.transform(immediateFuture, adder).get().intValue());
324 assertEquals(8, Futures.transform(immediateFuture, adder).get(
337 // We need to test with two input futures since ExecutionList.execute
343 Futures.transform(exceptionInput, newOneTimeExceptionThrower());
349 Futures.transform(errorInput, newOneTimeErrorThrower());
359 Futures.transform(exceptionInput, newOneTimeExceptionThrower());
362 runGetIdempotencyTest(Futures.transform(errorInput, newOneTimeErrorThrower()), MyError.class);
427 ListenableFuture<Object> future = Futures.transform(
428 Futures.immediateFuture(value),
438 Future<String> input = Futures.immediateFuture("foo");
439 Future<String> transformed = Futures.lazyTransform(input, spy);
454 Future<String> transformed = Futures.lazyTransform(Futures.immediateFuture(1), function);
491 ListenableFuture<Integer> originalFuture = Futures.immediateFuture(7);
494 ListenableFuture<Integer> faultToleranteFuture = Futures.withFallback(originalFuture, fallback);
503 expect(fallback.create(raisedException)).andReturn(Futures.immediateFuture(20));
504 ListenableFuture<Integer> failingFuture = Futures.immediateFailedFuture(raisedException);
507 ListenableFuture<Integer> faultToleranteFuture = Futures.withFallback(failingFuture, fallback);
530 ListenableFuture<Integer> failingFuture = Futures.immediateFailedFuture(new RuntimeException());
532 Futures.withFallback(failingFuture, fallback).get();
560 Futures.<Integer>immediateFailedFuture(expectedException));
563 ListenableFuture<Integer> failingFuture = Futures.immediateFailedFuture(raisedException);
566 ListenableFuture<Integer> faultToleranteFuture = Futures.withFallback(failingFuture, fallback);
585 ListenableFuture<Integer> derived = Futures.withFallback(primary, fallback);
596 ListenableFuture<Integer> derived = Futures.withFallback(primary, fallback);
609 ListenableFuture<Integer> derived = Futures.withFallback(primary, fallback);
622 ListenableFuture<Integer> failingFuture = Futures.immediateFailedFuture(raisedException);
625 ListenableFuture<Integer> derived = Futures.withFallback(failingFuture, fallback);
633 ListenableFuture<?> nullFuture = Futures.immediateFuture(null);
635 Futures.transform(nullFuture, constantAsyncFunction(nullFuture));
650 ListenableFuture<FooChild> future = Futures.immediateFuture(null);
660 Bar bar = Futures.transform(future, function).get();
666 AsyncFunction<String, Integer> function = constantAsyncFunction(Futures.immediateFuture(1));
667 ListenableFuture<Integer> future = Futures.transform(
683 ListenableFuture<Integer> outputFuture = Futures.transform(inputFuture, function);
706 ListenableFuture<Integer> future = Futures.transform(
723 ListenableFuture<?> inner = Futures.immediateFuture(null);
725 Futures.<ListenableFuture<?>>immediateFuture(inner);
726 ListenableFuture<?> dereferenced = Futures.dereference(outer);
732 ListenableFuture<FooChild> inner = Futures.immediateFuture(fooChild);
733 ListenableFuture<ListenableFuture<FooChild>> outer = Futures.immediateFuture(inner);
734 ListenableFuture<Foo> dereferenced = Futures.<Foo>dereference(outer);
740 ListenableFuture<Foo> dereferenced = Futures.dereference(outer);
747 ListenableFuture<ListenableFuture<Foo>> outer = Futures.immediateFuture(inner);
748 ListenableFuture<Foo> dereferenced = Futures.dereference(outer);
755 ListenableFuture<Foo> dereferenced = Futures.dereference(outer);
762 ListenableFuture<ListenableFuture<Foo>> outer = Futures.immediateFuture(inner);
763 ListenableFuture<Foo> dereferenced = Futures.dereference(outer);
806 Futures.allAsList(future1, future2, future3);
830 List<ListenableFuture<String>> futures = ImmutableList.of();
831 ListenableFuture<List<String>> compound = Futures.allAsList(futures);
842 ListenableFuture<List<String>> compound = Futures.allAsList();
855 Futures.allAsList(future1, future2);
875 ListenableFuture<String> future = Futures.immediateFailedFuture(exception);
876 ListenableFuture<List<String>> compound = Futures.allAsList(ImmutableList.of(future));
888 ListenableFuture<String> future1 = Futures.immediateFailedFuture(exception);
889 ListenableFuture<String> future2 = Futures.immediateFuture("results");
890 ListenableFuture<List<String>> compound = Futures.allAsList(ImmutableList.of(future1, future2));
903 ListenableFuture<String> future2 = Futures.immediateFuture("results");
904 ListenableFuture<List<String>> compound = Futures.allAsList(ImmutableList.of(future1, future2));
921 Futures.allAsList(future1, future2);
943 Futures.allAsList(future1, future2);
958 Futures.allAsList(future1, future2);
969 * Test the case where the futures are fulfilled prior to
971 * loop that connects a Listener to each of the futures would die
973 * variable being looped over (the list of futures).
988 Futures.allAsList(future1, future2, future3);
1008 Futures.allAsList(immediateFailedFuture(new MyException())).get();
1023 Futures.allAsList(immediateFailedFuture(new MyError())).get();
1039 Futures.allAsList(immediateFailedFuture(new MyException()),
1078 * A collection of several futures, covering cancellation, success, and
1080 * both immediate and delayed. We use each possible pair of these futures in
1084 * delayed futures each time, as the old delayed futures were completed as
1175 * All the futures, together with human-readable names for use by
1268 * {@link Futures#allAsList(Iterable)} or
1269 * {@link Futures#successfulAsList(Iterable)}, hidden behind a common
1326 * For each possible pair of futures
1327 * possible completion order of those futures, test that various get calls
1344 // Test timed get before we've completed any delayed futures.
1375 // Finish the two futures in the currently specified order:
1379 // Test untimed get now that we've completed any delayed futures.
1400 * input futures that we know makes it up isn't done yet), then we call it in
1449 Futures.successfulAsList(future1, future2, future3);
1473 List<ListenableFuture<String>> futures = ImmutableList.of();
1474 ListenableFuture<List<String>> compound = Futures.successfulAsList(futures);
1485 ListenableFuture<List<String>> compound = Futures.successfulAsList();
1498 Futures.successfulAsList(future1, future2);
1519 Futures.successfulAsList(future1, future2);
1540 Futures.successfulAsList(future1, future2);
1560 Futures.successfulAsList(future1, future2);
1600 Futures.successfulAsList(ImmutableList.of(SettableFuture.create()))
1612 Futures.successfulAsList(future1, future2);
1646 Futures.successfulAsList(future1, future2);
1663 Futures.successfulAsList(future1, future2, future3);
1685 Futures.successfulAsList(
1692 Futures.successfulAsList(
1706 Futures.successfulAsList(
1715 ListenableFuture<Foo> wrapper = Futures.nonCancellationPropagating(input);
1726 ListenableFuture<Foo> wrapper = Futures.nonCancellationPropagating(input);
1742 ListenableFuture<Foo> wrapper = Futures.nonCancellationPropagating(input);
1751 ListenableFuture<Foo> wrapper = Futures.nonCancellationPropagating(input);
1783 CheckedFuture<String, TestException> checked = Futures.makeChecked(
1823 CheckedFuture<String, TestException> checked = Futures.makeChecked(
1866 CheckedFuture<String, TestException> checked = Futures.makeChecked(
1899 CheckedFuture<String, TestException> checked = Futures.makeChecked(
1922 CheckedFuture<String, TestException> checked = Futures.makeChecked(
1939 CheckedFuture<String, TestException> checked = Futures.makeChecked(
1956 CheckedFuture<String, TestException> checked = Futures.makeChecked(
2352 ImmutableList<ListenableFuture<Long>> futures = Futures.inCompletionOrder(
2361 for (ListenableFuture<Long> future : futures) {
2374 ImmutableList<ListenableFuture<Long>> futures = Futures.inCompletionOrder(
2383 for (ListenableFuture<Long> future : futures) {
2406 ImmutableList<ListenableFuture<Long>> futures = Futures.inCompletionOrder(
2415 for (ListenableFuture<Long> future : futures) {
2434 ImmutableList<ListenableFuture<Long>> delegates = Futures.inCompletionOrder(
2456 ImmutableList<ListenableFuture<Object>> futures = Futures.inCompletionOrder(inputs);
2463 assertEquals(expected.get(i), futures.get(i).get());
2575 .forAllPublicStaticMethods(Futures.class)
