Home
last modified time | relevance | path

Searched refs:ListenableFuture (Results 1 – 25 of 136) sorted by relevance

123456

/external/guava/guava-tests/test/com/google/common/util/concurrent/
DFuturesTest.java110 ListenableFuture<String> future = Futures.immediateFuture(DATA1); in testImmediateFuture()
117 ListenableFuture<String> future1 = Futures.immediateFuture(DATA1); in testMultipleImmediateFutures()
118 ListenableFuture<String> future2 = Futures.immediateFuture(DATA2); in testMultipleImmediateFutures()
127 ListenableFuture<String> future = in testImmediateFailedFuture()
141 ListenableFuture<String> future = in testImmediateFailedFuture_cancellationException()
155 ListenableFuture<String> future = in testImmediateCancelledFuture()
213 ListenableFuture<?> nullFuture = Futures.immediateFuture(null); in testTransform_genericsNull()
214 ListenableFuture<?> transformedFuture = in testTransform_genericsNull()
220 ListenableFuture<FooChild> future = Futures.immediateFuture(null); in testTransform_genericsHierarchy()
234 @Override public ListenableFuture<Bar> apply(Foo unused) { in testTransform_cancelPropagatesToInput()
[all …]
DFuturesTransformAsyncFunctionTest.java45 @Override protected ListenableFuture<String> buildChainingFuture( in buildChainingFuture()
46 ListenableFuture<Integer> inputFuture) { in buildChainingFuture()
59 public ListenableFuture<String> apply(Integer input) { in apply()
164 ListenableFuture<String> chain = buildChainingFuture(badInput); in testFutureGetThrowsRuntimeException()
178 protected BadFuture(ListenableFuture<Integer> delegate) { in BadFuture()
DJdkFutureAdaptersTest.java50 ListenableFuture<String> listenableFuture = immediateFuture(DATA1); in testListenInPoolThreadReturnsSameFuture()
60 ListenableFuture<String> listenableFuture = in testListenInPoolThreadIgnoresExecutorWhenDelegateIsDone()
88 ListenableFuture<String> listenableFuture = in testListenInPoolThreadUsesGivenExecutor()
122 ListenableFuture<String> listenableFuture = in testListenInPoolThreadCustomExecutorInterrupted()
231 ListenableFuture.class.isInstance(input)); in testListenInPoolThreadRunsListenerAfterRuntimeException()
232 ListenableFuture<String> listenable = listenInPoolThread(input); in testListenInPoolThreadRunsListenerAfterRuntimeException()
DFutureCallbackTest.java86 ListenableFuture<String> f = ThrowingFuture.throwingError(error); in testThrowErrorFromGet()
93 ListenableFuture<String> f = ThrowingFuture.throwingRuntimeException(e); in testRuntimeExeceptionFromGet()
134 ListenableFuture<?> f = settable; in testWildcardFuture()
165 private static class ThrowingFuture<V> implements ListenableFuture<V> {
169 public static <V> ListenableFuture<V> throwingError(Error error) { in throwingError()
173 public static <V> ListenableFuture<V>
/external/guava/guava/src/com/google/common/util/concurrent/
DFutures.java91 ListenableFuture<V> future, Function<? super Exception, X> mapper) { in makeChecked()
96 implements ListenableFuture<V> {
246 public static <V> ListenableFuture<V> immediateFuture(@Nullable V value) { in immediateFuture()
272 public static <V> ListenableFuture<V> immediateFailedFuture( in immediateFailedFuture()
284 public static <V> ListenableFuture<V> immediateCancelledFuture() { in immediateCancelledFuture()
376 public static <V> ListenableFuture<V> withFallback( in withFallback()
377 ListenableFuture<? extends V> input, in withFallback()
440 public static <V> ListenableFuture<V> withFallback( in withFallback()
441 ListenableFuture<? extends V> input, in withFallback()
453 private volatile ListenableFuture<? extends V> running;
[all …]
DAbstractListeningExecutorService.java49 @Override public ListenableFuture<?> submit(Runnable task) { in submit()
50 return (ListenableFuture<?>) super.submit(task); in submit()
53 @Override public <T> ListenableFuture<T> submit(Runnable task, @Nullable T result) { in submit()
54 return (ListenableFuture<T>) super.submit(task, result); in submit()
57 @Override public <T> ListenableFuture<T> submit(Callable<T> task) { in submit()
58 return (ListenableFuture<T>) super.submit(task); in submit()
DJdkFutureAdapters.java58 public static <V> ListenableFuture<V> listenInPoolThread( in listenInPoolThread()
60 if (future instanceof ListenableFuture) { in listenInPoolThread()
61 return (ListenableFuture<V>) future; in listenInPoolThread()
90 public static <V> ListenableFuture<V> listenInPoolThread( in listenInPoolThread()
93 if (future instanceof ListenableFuture) { in listenInPoolThread()
94 return (ListenableFuture<V>) future; in listenInPoolThread()
110 implements ListenableFuture<V> {
DForwardingListenableFuture.java37 implements ListenableFuture<V> {
43 protected abstract ListenableFuture<V> delegate(); in delegate()
63 private final ListenableFuture<V> delegate;
65 protected SimpleForwardingListenableFuture(ListenableFuture<V> delegate) { in SimpleForwardingListenableFuture()
70 protected final ListenableFuture<V> delegate() { in delegate()
DAsyncSettableFuture.java45 private final ListenableFuture<V> dereferenced = Futures.dereference(nested);
49 @Override protected ListenableFuture<V> delegate() { in delegate()
57 public boolean setFuture(ListenableFuture<? extends V> future) { in setFuture()
91 private static final class NestedFuture<V> extends AbstractFuture<ListenableFuture<? extends V>> {
92 boolean setFuture(ListenableFuture<? extends V> value) { in setFuture()
DForwardingListeningExecutorService.java39 public <T> ListenableFuture<T> submit(Callable<T> task) { in submit()
44 public ListenableFuture<?> submit(Runnable task) { in submit()
49 public <T> ListenableFuture<T> submit(Runnable task, T result) { in submit()
/external/dagger2/compiler/src/it/producers-functional-tests/src/main/java/producerstest/
DSimpleProducerModule.java20 import com.google.common.util.concurrent.ListenableFuture;
48 static ListenableFuture<String> throwingProducer() { in throwingProducer()
54 static ListenableFuture<String> settableFutureStr(SettableFuture<String> future) { in settableFutureStr()
66 static ListenableFuture<String> futureStr() { in futureStr()
78 static ListenableFuture<String> futureStrWithArg(int i) { in futureStrWithArg()
90 static ListenableFuture<String> futureStrThrowingException() throws IOException { in futureStrThrowingException()
102 static ListenableFuture<String> futureStrWithArgThrowingException(int i) throws IOException { in futureStrWithArgThrowingException()
121 static ListenableFuture<String> futureStrWithArgs( in futureStrWithArgs()
128 static ListenableFuture<String> futureStrWithArgsThrowingException( in futureStrWithArgsThrowingException()
146 static ListenableFuture<String> setOfStrFutureElement() { in setOfStrFutureElement()
[all …]
DMultibindingComponent.java18 import com.google.common.util.concurrent.ListenableFuture;
26 ListenableFuture<Set<String>> strs(); in strs()
27 ListenableFuture<Integer> strCount(); in strCount()
29 ListenableFuture<Set<Produced<String>>> successfulSet(); in successfulSet()
32 ListenableFuture<Set<Produced<String>>> possiblyThrowingSet(); in possiblyThrowingSet()
/external/dagger2/producers/src/test/java/dagger/producers/internal/
DProducersTest.java19 import com.google.common.util.concurrent.ListenableFuture;
40 ListenableFuture<String> future = Futures.immediateFuture("monkey"); in createFutureProduced_success()
41 ListenableFuture<Produced<String>> producedFuture = Producers.createFutureProduced(future); in createFutureProduced_success()
47 ListenableFuture<String> future = Futures.immediateFailedFuture(new RuntimeException("monkey")); in createFutureProduced_failure()
48 ListenableFuture<Produced<String>> producedFuture = Producers.createFutureProduced(future); in createFutureProduced_failure()
54 ListenableFuture<String> future = SettableFuture.create(); in createFutureProduced_cancelPropagatesBackwards()
55 ListenableFuture<Produced<String>> producedFuture = Producers.createFutureProduced(future); in createFutureProduced_cancelPropagatesBackwards()
62 ListenableFuture<String> future = SettableFuture.create(); in createFutureProduced_cancelDoesNotPropagateForwards()
63 ListenableFuture<Produced<String>> producedFuture = Producers.createFutureProduced(future); in createFutureProduced_cancelDoesNotPropagateForwards()
81 ListenableFuture<String> future = Futures.immediateFuture("monkey"); in createFutureSingletonSet_success()
[all …]
DAbstractProducerTest.java19 import com.google.common.util.concurrent.ListenableFuture;
81 public ListenableFuture<Integer> compute(ProducerMonitor unusedMonitor) { in get()
95 ListenableFuture<Integer> future = producer.get(); in monitor_success()
97 verify(monitor).addCallbackTo(any(ListenableFuture.class)); in monitor_success()
109 ListenableFuture<Integer> future = producer.get(); in monitor_failure()
111 verify(monitor).addCallbackTo(any(ListenableFuture.class)); in monitor_failure()
130 private final ListenableFuture<T> delegate;
134 ListenableFuture<T> delegate) { in DelegateProducer()
140 public ListenableFuture<T> compute(ProducerMonitor unusedMonitor) { in compute()
/external/guava/guava-tests/benchmark/com/google/common/util/concurrent/
DFuturesCombineBenchmark.java39 @Override <V> ListenableFuture<V> combine(final Callable<V> combiner, Executor executor, in combine()
40 Iterable<? extends ListenableFuture<?>> futures) { in combine()
41 ListenableFuture<?> trigger = Futures.successfulAsList(futures); in combine()
45 @Override public ListenableFuture<V> apply(Object arg) throws Exception { in combine()
59 <V> ListenableFuture<V> combine(Callable<V> combiner, final Executor executor,
60 Iterable<? extends ListenableFuture<?>> futures) {
65 abstract <V> ListenableFuture<V> combine(
67 Iterable<? extends ListenableFuture<?>> futures);
80 ImmutableList.Builder<ListenableFuture<?>> futuresBuilder = ImmutableList.builder();
84 ImmutableList<ListenableFuture<?>> futures = futuresBuilder.build();
[all …]
/external/dagger2/producers/src/main/java/dagger/producers/internal/
DProducers.java22 import com.google.common.util.concurrent.ListenableFuture;
50 public static <T> ListenableFuture<Produced<T>> createFutureProduced(ListenableFuture<T> future) { in createFutureProduced()
67 @Override public ListenableFuture<Produced<Object>> create(final Throwable t) {
82 public static <T> ListenableFuture<Set<T>> createFutureSingletonSet(ListenableFuture<T> future) {
98 protected ListenableFuture<T> compute(ProducerMonitor unusedMonitor) {
108 public ListenableFuture<T> get() {
118 public ListenableFuture<T> get() {
DAbstractProducer.java18 import com.google.common.util.concurrent.ListenableFuture;
39 private volatile ListenableFuture<T> instance = null;
52 protected abstract ListenableFuture<T> compute(ProducerMonitor monitor); in compute()
55 public final ListenableFuture<T> get() { in get()
57 ListenableFuture<T> result = instance; in get()
DSetProducer.java21 import com.google.common.util.concurrent.ListenableFuture;
66 public ListenableFuture<Set<T>> compute(ProducerMonitor unusedMonitor) { in compute()
67 List<ListenableFuture<Set<T>>> futureSets = in compute()
68 new ArrayList<ListenableFuture<Set<T>>>(contributingProducers.size()); in compute()
70 ListenableFuture<Set<T>> futureSet = producer.get(); in compute()
DSetOfProducedProducer.java21 import com.google.common.util.concurrent.ListenableFuture;
68 public ListenableFuture<Set<Produced<T>>> compute(ProducerMonitor unusedMonitor) { in compute()
69 List<ListenableFuture<Produced<Set<T>>>> futureProducedSets = in compute()
70 new ArrayList<ListenableFuture<Produced<Set<T>>>>(contributingProducers.size()); in compute()
72 ListenableFuture<Set<T>> futureSet = producer.get(); in compute()
/external/caliper/caliper/src/main/java/com/google/caliper/runner/
DExperimentingCaliperRun.java35 import com.google.common.util.concurrent.ListenableFuture;
62 final ListenableFuture<Object> nullFuture = Futures.immediateFuture(null);
63 @Override public ListenableFuture<Object> create(Throwable t) throws Exception {
156 List<ListenableFuture<TrialResult>> pendingTrials = scheduleTrials(trials, executor); in run()
160 for (ListenableFuture<TrialResult> trialFuture : inCompletionOrder(pendingTrials)) { in run()
171 for (ListenableFuture<?> toCancel : pendingTrials) { in run()
178 for (ListenableFuture<?> toCancel : pendingTrials) { in run()
205 private List<ListenableFuture<TrialResult>> scheduleTrials(List<ScheduledTrial> trials, in scheduleTrials()
207 List<ListenableFuture<TrialResult>> pendingTrials = Lists.newArrayList(); in scheduleTrials()
218 ListenableFuture<?> previous = Futures.successfulAsList(pendingTrials); in scheduleTrials()
[all …]
/external/dagger2/compiler/src/it/producers-functional-tests/src/main/java/producerstest/badexecutor/
DSimpleComponent.java18 import com.google.common.util.concurrent.ListenableFuture;
28 ListenableFuture<String> noArgStr(); in noArgStr()
31 ListenableFuture<Integer> singleArgInt(); in singleArgInt()
34 ListenableFuture<Boolean> singleArgBool(); in singleArgBool()
37 ListenableFuture<Double> doubleDep(); in doubleDep()
/external/guava/guava-testlib/src/com/google/common/util/concurrent/testing/
DSameThreadScheduledExecutorService.java23 import com.google.common.util.concurrent.ListenableFuture;
81 public <T> ListenableFuture<T> submit(Callable<T> task) { in submit()
87 public <T> ListenableFuture<T> submit(Runnable task, T result) { in submit()
94 public ListenableFuture<?> submit(Runnable task) { in submit()
151 protected ImmediateScheduledFuture(ListenableFuture<V> future) { in ImmediateScheduledFuture()
180 ListenableFuture<V> delegateFuture = submit(callable); in schedule()
/external/grpc-grpc-java/services/src/test/java/io/grpc/services/
DChannelzTestHelper.java20 import com.google.common.util.concurrent.ListenableFuture;
65 public ListenableFuture<SocketStats> getStats() { in getStats()
95 public ListenableFuture<SocketStats> getStats() { in getStats()
130 public ListenableFuture<ServerStats> getStats() { in getStats()
164 public ListenableFuture<ChannelStats> getStats() { in getStats()
/external/dagger2/compiler/src/it/producers-functional-tests/src/main/java/producerstest/builder/
DTestComponentWithBuilder.java18 import com.google.common.util.concurrent.ListenableFuture;
27 ListenableFuture<String> s(); in s()
28 ListenableFuture<Double> d(); in d()
/external/dagger2/compiler/src/it/producers-functional-tests/src/main/java/producerstest/monitoring/
DServingModule.java18 import com.google.common.util.concurrent.ListenableFuture;
41 static ListenableFuture<String> callServer1( in callServer1()
47 static ListenableFuture<String> callServer2( in callServer2()

123456