Lines Matching defs:Futures
21 import static com.google.common.util.concurrent.Futures.allAsList;
22 import static com.google.common.util.concurrent.Futures.get;
23 import static com.google.common.util.concurrent.Futures.getUnchecked;
24 import static com.google.common.util.concurrent.Futures.immediateFailedFuture;
25 import static com.google.common.util.concurrent.Futures.immediateFuture;
26 import static com.google.common.util.concurrent.Futures.successfulAsList;
74 * Unit tests for {@link Futures}.
76 * TODO: Add tests for other Futures methods
82 "com.google.common.util.concurrent.Futures$CombinedFuture");
110 ListenableFuture<String> future = Futures.immediateFuture(DATA1);
117 ListenableFuture<String> future1 = Futures.immediateFuture(DATA1);
118 ListenableFuture<String> future2 = Futures.immediateFuture(DATA2);
128 Futures.immediateFailedFuture(exception);
142 Futures.immediateFailedFuture(exception);
156 Futures.immediateCancelledFuture();
163 CheckedFuture<String, MyException> future = Futures.immediateCheckedFuture(
172 CheckedFuture<String, MyException> future1 = Futures.immediateCheckedFuture(
174 CheckedFuture<String, MyException> future2 = Futures.immediateCheckedFuture(
187 Futures.immediateFailedCheckedFuture(exception);
213 ListenableFuture<?> nullFuture = Futures.immediateFuture(null);
215 Futures.transform(nullFuture, Functions.constant(null));
220 ListenableFuture<FooChild> future = Futures.immediateFuture(null);
227 Bar bar = Futures.transform(future, function).get();
238 assertTrue(Futures.transform(input, function).cancel(false));
250 assertTrue(Futures.transform(input, function).cancel(true));
256 ListenableFuture<Foo> immediate = Futures.immediateFuture(new Foo());
263 assertTrue(Futures.transform(immediate, function).cancel(false));
270 ListenableFuture<Foo> immediate = Futures.immediateFuture(new Foo());
277 assertTrue(Futures.transform(immediate, function).cancel(true));
287 Futures.transform(input, Functions.toStringFunction(), executor);
318 ListenableFuture<Integer> immediateFuture = Futures.immediateFuture(4);
319 Future<Integer> transformedFuture = Futures.transform(immediateFuture, adder);
339 assertEquals(8, Futures.transform(immediateFuture, adder).get().intValue());
342 assertEquals(8, Futures.transform(immediateFuture, adder).get(
355 // We need to test with two input futures since ExecutionList.execute
361 Futures.transform(exceptionInput, newOneTimeExceptionThrower());
367 Futures.transform(errorInput, newOneTimeErrorThrower());
377 Futures.transform(exceptionInput, newOneTimeExceptionThrower());
380 runGetIdempotencyTest(Futures.transform(errorInput, newOneTimeErrorThrower()), MyError.class);
445 ListenableFuture<Object> future = Futures.transform(
446 Futures
456 Future<String> input = Futures.immediateFuture("foo");
457 Future<String> transformed = Futures.lazyTransform(input, spy);
472 Future<String> transformed = Futures.lazyTransform(Futures.immediateFuture(1), function);
509 ListenableFuture<Integer> originalFuture = Futures.immediateFuture(7);
512 ListenableFuture<Integer> faultToleranteFuture = Futures.withFallback(originalFuture, fallback);
521 expect(fallback.create(raisedException)).andReturn(Futures.immediateFuture(20));
522 ListenableFuture<Integer> failingFuture = Futures.immediateFailedFuture(raisedException);
525 ListenableFuture<Integer> faultToleranteFuture = Futures.withFallback(failingFuture, fallback);
548 ListenableFuture<Integer> failingFuture = Futures.immediateFailedFuture(new RuntimeException());
550 Futures.withFallback(failingFuture, fallback).get();
578 Futures.<Integer>immediateFailedFuture(expectedException));
581 ListenableFuture<Integer> failingFuture = Futures.immediateFailedFuture(raisedException);
584 ListenableFuture<Integer> faultToleranteFuture = Futures.withFallback(failingFuture, fallback);
603 ListenableFuture<Integer> derived = Futures.withFallback(primary, fallback);
614 ListenableFuture<Integer> derived = Futures.withFallback(primary, fallback);
627 ListenableFuture<Integer> derived = Futures.withFallback(primary, fallback);
640 ListenableFuture<Integer> failingFuture = Futures.immediateFailedFuture(raisedException);
643 ListenableFuture<Integer> derived = Futures.withFallback(failingFuture, fallback);
651 ListenableFuture<?> nullFuture = Futures.immediateFuture(null);
653 Futures.transform(nullFuture, constantAsyncFunction(nullFuture));
668 ListenableFuture<FooChild> future = Futures.immediateFuture(null);
678 Bar bar = Futures.transform(future, function).get();
684 AsyncFunction<String, Integer> function = constantAsyncFunction(Futures.immediateFuture(1));
685 ListenableFuture<Integer> future = Futures.transform(
701 ListenableFuture<Integer> outputFuture = Futures.transform(inputFuture, function);
724 ListenableFuture<Integer> future = Futures.transform(
741 ListenableFuture<?> inner = Futures.immediateFuture(null);
743 Futures.<ListenableFuture<?>>immediateFuture(inner);
744 ListenableFuture<?> dereferenced = Futures.dereference(outer);
750 ListenableFuture<FooChild> inner = Futures.immediateFuture(fooChild);
751 ListenableFuture<ListenableFuture<FooChild>> outer = Futures.immediateFuture(inner);
752 ListenableFuture<Foo> dereferenced = Futures.<Foo>dereference(outer);
758 ListenableFuture<Foo> dereferenced = Futures.dereference(outer);
765 ListenableFuture<ListenableFuture<Foo>> outer = Futures.immediateFuture(inner);
766 ListenableFuture<Foo> dereferenced = Futures.dereference(outer);
773 ListenableFuture<Foo> dereferenced = Futures.dereference(outer);
780 ListenableFuture<ListenableFuture<Foo>> outer = Futures.immediateFuture(inner);
781 ListenableFuture<Foo> dereferenced = Futures.dereference(outer);
824 Futures.allAsList(future1, future2, future3);
848 List<ListenableFuture<String>> futures = ImmutableList.of();
849 ListenableFuture<List<String>> compound = Futures.allAsList(futures);
860 ListenableFuture<List<String>> compound = Futures.allAsList();
873 Futures.allAsList(future1, future2);
893 ListenableFuture<String> future = Futures.immediateFailedFuture(exception);
894 ListenableFuture<List<String>> compound = Futures.allAsList(ImmutableList.of(future));
906 ListenableFuture<String> future1 = Futures.immediateFailedFuture(exception);
907 ListenableFuture<String> future2 = Futures.immediateFuture("results");
908 ListenableFuture<List<String>> compound = Futures.allAsList(ImmutableList.of(future1, future2));
921 ListenableFuture<String> future2 = Futures.immediateFuture("results");
922 ListenableFuture<List<String>> compound = Futures.allAsList(ImmutableList.of(future1, future2));
939 Futures.allAsList(future1, future2);
961 Futures.allAsList(future1, future2);
976 Futures.allAsList(future1, future2);
987 * Test the case where the futures are fulfilled prior to
989 * loop that connects a Listener to each of the futures would die
991 * variable being looped over (the list of futures).
1006 Futures.allAsList(future1, future2, future3);
1026 Futures.allAsList(immediateFailedFuture(new MyException())).get();
1041 Futures.allAsList(immediateFailedFuture(new MyError())).get();
1057 Futures.allAsList(immediateFailedFuture(new MyException()),
1096 * A collection of several futures, covering cancellation, success, and
1098 * both immediate and delayed. We use each possible pair of these futures in
1102 * delayed futures each time, as the old delayed futures were completed as
1193 * All the futures, together with human-readable names for use by
1286 * {@link Futures#allAsList(Iterable)} or
1287 * {@link Futures#successfulAsList(Iterable)}, hidden behind a common
1344 * For each possible pair of futures from {@link TestFutureBatch}, for each
1345 * possible completion order of those futures, test that various get calls
1362 // Test timed get before we've completed any delayed futures.
1393 // Finish the two futures in the currently specified order:
1397 // Test untimed get now that we've completed any delayed futures.
1418 * input futures that we know makes it up isn't done yet), then we call it in
1467 Futures.successfulAsList(future1, future2, future3);
1491 List<ListenableFuture<String>> futures = ImmutableList.of();
1492 ListenableFuture<List<String>> compound = Futures.successfulAsList(futures);
1503 ListenableFuture<List<String>> compound = Futures.successfulAsList();
1516 Futures.successfulAsList(future1, future2);
1537 Futures.successfulAsList(future1, future2);
1558 Futures.successfulAsList(future1, future2);
1578 Futures.successfulAsList(future1, future2);
1618 Futures.successfulAsList(ImmutableList.of(SettableFuture.create()))
1630 Futures.successfulAsList(future1, future2);
1664 Futures.successfulAsList(future1, future2);
1681 Futures.successfulAsList(future1, future2, future3);
1703 Futures.successfulAsList(
1710 Futures.successfulAsList(
1724 Futures.successfulAsList(
1733 ListenableFuture<Foo> wrapper = Futures.nonCancellationPropagating(input);
1744 ListenableFuture<Foo> wrapper = Futures.nonCancellationPropagating(input);
1760 ListenableFuture<Foo> wrapper = Futures.nonCancellationPropagating(input);
1769 ListenableFuture<Foo> wrapper = Futures.nonCancellationPropagating(input);
1801 CheckedFuture<String, TestException> checked = Futures.makeChecked(
1841 CheckedFuture<String, TestException> checked = Futures.makeChecked(
1884 CheckedFuture<String, TestException> checked = Futures.makeChecked(
1917 CheckedFuture<String, TestException> checked = Futures.makeChecked(
1940 CheckedFuture<String, TestException> checked = Futures.makeChecked(
1957 CheckedFuture<String, TestException> checked = Futures.makeChecked(
1974 CheckedFuture<String, TestException> checked = Futures.makeChecked(
2370 ImmutableList<ListenableFuture<Long>> futures = Futures.inCompletionOrder(
2379 for (ListenableFuture<Long> future : futures) {
2392 ImmutableList<ListenableFuture<Long>> futures = Futures.inCompletionOrder(
2401 for (ListenableFuture<Long> future : futures) {
2424 ImmutableList<ListenableFuture<Long>> futures = Futures.inCompletionOrder(
2433 for (ListenableFuture<Long> future : futures) {
2452 ImmutableList<ListenableFuture<Long>> delegates = Futures.inCompletionOrder(
2474 ImmutableList<ListenableFuture<Object>> futures = Futures.inCompletionOrder(inputs);
2481 assertEquals(expected.get(i), futures.get(i).get());
2593 .forAllPublicStaticMethods(Futures.class)
