| /external/guava/android/guava-tests/test/com/google/common/util/concurrent/ |
| D | SettableFutureTest.java | 34 private SettableFuture<String> future;
41 future = SettableFuture.create(); in setUp()
82 SettableFuture<Integer> future = SettableFuture.create(); in testCreate()
88 SettableFuture<Integer> future = SettableFuture.create(); in testSetValue_simpleThreaded()
93 assertFalse(future.setFuture(SettableFuture.<Integer>create())); in testSetValue_simpleThreaded()
101 SettableFuture<Object> future = SettableFuture.create(); in testSetException()
107 assertFalse(future.setFuture(SettableFuture.create())); in testSetException()
120 SettableFuture<String> future = SettableFuture.create(); in testSetFuture()
121 SettableFuture<String> nested = SettableFuture.create(); in testSetFuture()
126 assertFalse(future.setFuture(SettableFuture.<String>create())); in testSetFuture()
[all …]
|
| D | FuturesTest.java | 283 SettableFuture<Object> root = SettableFuture.create();
288 SettableFuture<Object> root = SettableFuture.create();
311 SettableFuture<Object> input = SettableFuture.create();
331 SettableFuture<Object> input = SettableFuture.create();
366 SettableFuture<Object> input = SettableFuture.create();
385 SettableFuture<Foo> input = SettableFuture.create();
399 SettableFuture<Foo> input = SettableFuture.create();
415 SettableFuture<String> input = SettableFuture.create();
454 final SettableFuture<Bar> secondary = SettableFuture.create();
469 final SettableFuture<Bar> secondary = SettableFuture.create();
[all …]
|
| D | FutureCallbackTest.java | 39 SettableFuture<String> f = SettableFuture.create(); in testSameThreadSuccess()
47 SettableFuture<String> f = SettableFuture.create(); in testExecutorSuccess()
56 SettableFuture<String> f = SettableFuture.create(); in testSameThreadExecutionException()
64 SettableFuture<String> f = SettableFuture.create(); in testCancel()
103 SettableFuture<String> future = SettableFuture.create(); in testOnSuccessThrowsRuntimeException()
119 SettableFuture<String> future = SettableFuture.create(); in testOnSuccessThrowsError()
136 SettableFuture<String> settable = SettableFuture.create(); in testWildcardFuture()
|
| D | AbstractFutureTest.java | 214 assertThat(SettableFuture.create().toString()).isNotEqualTo(SettableFuture.create().toString()); in testToString_allUnique()
218 SettableFuture<Object> future = SettableFuture.create(); in testToString_oom()
234 SettableFuture<Object> future2 = SettableFuture.create(); in testToString_oom()
828 SettableFuture<String> orig = SettableFuture.create(); in testSetFuture_stackOverflow()
829 SettableFuture<String> prev = orig; in testSetFuture_stackOverflow()
831 SettableFuture<String> curr = SettableFuture.create(); in testSetFuture_stackOverflow()
845 SettableFuture<String> orig = SettableFuture.create(); in testSetFutureToString_stackOverflow()
846 SettableFuture<String> prev = orig; in testSetFutureToString_stackOverflow()
848 SettableFuture<String> curr = SettableFuture.create(); in testSetFutureToString_stackOverflow()
858 SettableFuture<String> future = SettableFuture.create(); in testSetFuture_misbehavingFutureThrows()
[all …]
|
| D | UninterruptibleFutureTest.java | 183 SettableFuture<String> future = SettableFuture.create(); in runUntimedInterruptsTest()
191 SettableFuture<String> future = SettableFuture.create(); in runTimedInterruptsTest()
198 int times, SettableFuture<String> future, FutureTask<Boolean> interruptReporter) in runNInterruptsTest()
216 SettableFuture<String> future = SettableFuture.create(); in testMakeUninterruptible_plainFutureSanityCheck()
233 SettableFuture<String> future = SettableFuture.create(); in testMakeUninterruptible_timedGetZeroTimeoutAttempted()
245 SettableFuture<String> future = SettableFuture.create(); in testMakeUninterruptible_timedGetNegativeTimeoutAttempted()
|
| D | FuturesGetCheckedTest.java | 61 SettableFuture<String> future = SettableFuture.create(); in testGetCheckedUntimed_interrupted()
75 SettableFuture<String> future = SettableFuture.create(); in testGetCheckedUntimed_cancelled()
175 SettableFuture<String> future = SettableFuture.create(); in testGetCheckedTimed_interrupted()
189 SettableFuture<String> future = SettableFuture.create(); in testGetCheckedTimed_cancelled()
254 SettableFuture<String> future = SettableFuture.create(); in testGetCheckedTimed_TimeoutException()
|
| D | ExecutionSequencerTest.java | 47 private SettableFuture<Void> firstFuture;
54 firstFuture = SettableFuture.create(); in setUp()
156 final SettableFuture<Void> settableFuture = SettableFuture.create(); in testCancellationWithReferencedObject()
226 final SettableFuture<Void> settableFuture = SettableFuture.create();
245 final SettableFuture<Void> settableFuture = SettableFuture.create();
273 final SettableFuture<Void> settableFuture = SettableFuture.create();
348 final SettableFuture<Void> settableFuture = SettableFuture.create();
412 TestCallable secondCallable = new TestCallable(SettableFuture.<Void>create());
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | SettableFutureTest.java | 34 private SettableFuture<String> future;
41 future = SettableFuture.create(); in setUp()
82 SettableFuture<Integer> future = SettableFuture.create(); in testCreate()
88 SettableFuture<Integer> future = SettableFuture.create(); in testSetValue_simpleThreaded()
93 assertFalse(future.setFuture(SettableFuture.<Integer>create())); in testSetValue_simpleThreaded()
101 SettableFuture<Object> future = SettableFuture.create(); in testSetException()
107 assertFalse(future.setFuture(SettableFuture.create())); in testSetException()
120 SettableFuture<String> future = SettableFuture.create(); in testSetFuture()
121 SettableFuture<String> nested = SettableFuture.create(); in testSetFuture()
126 assertFalse(future.setFuture(SettableFuture.<String>create())); in testSetFuture()
[all …]
|
| D | FuturesTest.java | 283 SettableFuture<Object> root = SettableFuture.create();
288 SettableFuture<Object> root = SettableFuture.create();
311 SettableFuture<Object> input = SettableFuture.create();
331 SettableFuture<Object> input = SettableFuture.create();
366 SettableFuture<Object> input = SettableFuture.create();
385 SettableFuture<Foo> input = SettableFuture.create();
399 SettableFuture<Foo> input = SettableFuture.create();
415 SettableFuture<String> input = SettableFuture.create();
454 final SettableFuture<Bar> secondary = SettableFuture.create();
469 final SettableFuture<Bar> secondary = SettableFuture.create();
[all …]
|
| D | FutureCallbackTest.java | 39 SettableFuture<String> f = SettableFuture.create(); in testSameThreadSuccess()
47 SettableFuture<String> f = SettableFuture.create(); in testExecutorSuccess()
56 SettableFuture<String> f = SettableFuture.create(); in testSameThreadExecutionException()
64 SettableFuture<String> f = SettableFuture.create(); in testCancel()
103 SettableFuture<String> future = SettableFuture.create(); in testOnSuccessThrowsRuntimeException()
119 SettableFuture<String> future = SettableFuture.create(); in testOnSuccessThrowsError()
136 SettableFuture<String> settable = SettableFuture.create(); in testWildcardFuture()
|
| D | AbstractFutureTest.java | 214 assertThat(SettableFuture.create().toString()).isNotEqualTo(SettableFuture.create().toString()); in testToString_allUnique()
218 SettableFuture<Object> future = SettableFuture.create(); in testToString_oom()
234 SettableFuture<Object> future2 = SettableFuture.create(); in testToString_oom()
828 SettableFuture<String> orig = SettableFuture.create(); in testSetFuture_stackOverflow()
829 SettableFuture<String> prev = orig; in testSetFuture_stackOverflow()
831 SettableFuture<String> curr = SettableFuture.create(); in testSetFuture_stackOverflow()
845 SettableFuture<String> orig = SettableFuture.create(); in testSetFutureToString_stackOverflow()
846 SettableFuture<String> prev = orig; in testSetFutureToString_stackOverflow()
848 SettableFuture<String> curr = SettableFuture.create(); in testSetFutureToString_stackOverflow()
858 SettableFuture<String> future = SettableFuture.create(); in testSetFuture_misbehavingFutureThrows()
[all …]
|
| D | UninterruptibleFutureTest.java | 183 SettableFuture<String> future = SettableFuture.create(); in runUntimedInterruptsTest()
191 SettableFuture<String> future = SettableFuture.create(); in runTimedInterruptsTest()
198 int times, SettableFuture<String> future, FutureTask<Boolean> interruptReporter) in runNInterruptsTest()
216 SettableFuture<String> future = SettableFuture.create(); in testMakeUninterruptible_plainFutureSanityCheck()
233 SettableFuture<String> future = SettableFuture.create(); in testMakeUninterruptible_timedGetZeroTimeoutAttempted()
245 SettableFuture<String> future = SettableFuture.create(); in testMakeUninterruptible_timedGetNegativeTimeoutAttempted()
|
| D | FuturesGetCheckedTest.java | 61 SettableFuture<String> future = SettableFuture.create(); in testGetCheckedUntimed_interrupted()
75 SettableFuture<String> future = SettableFuture.create(); in testGetCheckedUntimed_cancelled()
175 SettableFuture<String> future = SettableFuture.create(); in testGetCheckedTimed_interrupted()
189 SettableFuture<String> future = SettableFuture.create(); in testGetCheckedTimed_cancelled()
254 SettableFuture<String> future = SettableFuture.create(); in testGetCheckedTimed_TimeoutException()
|
| D | ExecutionSequencerTest.java | 47 private SettableFuture<Void> firstFuture;
54 firstFuture = SettableFuture.create(); in setUp()
156 final SettableFuture<Void> settableFuture = SettableFuture.create(); in testCancellationWithReferencedObject()
226 final SettableFuture<Void> settableFuture = SettableFuture.create();
245 final SettableFuture<Void> settableFuture = SettableFuture.create();
273 final SettableFuture<Void> settableFuture = SettableFuture.create();
348 final SettableFuture<Void> settableFuture = SettableFuture.create();
412 TestCallable secondCallable = new TestCallable(SettableFuture.<Void>create());
|
| /external/dagger2/javatests/dagger/functional/producers/ |
| D | ProducerFactoryTest.java | 27 import com.google.common.util.concurrent.SettableFuture;
91 SettableFuture<Integer> intFuture = SettableFuture.create(); in singleArgMethod()
105 SettableFuture<String> strFuture = SettableFuture.create(); in successMonitor()
107 SettableFuture<SettableFuture<String>> strFutureFuture = SettableFuture.create(); in successMonitor()
108 CancellableProducer<SettableFuture<String>> strFutureProducer = in successMonitor()
134 SettableFuture<String> strFuture = SettableFuture.create(); in failureMonitor()
136 SettableFuture<SettableFuture<String>> strFutureFuture = SettableFuture.create(); in failureMonitor()
137 CancellableProducer<SettableFuture<String>> strFutureProducer = in failureMonitor()
|
| /external/grpc-grpc-java/services/src/test/java/io/grpc/services/ |
| D | ChannelzTestHelper.java | 21 import com.google.common.util.concurrent.SettableFuture;
66 SettableFuture<SocketStats> ret = SettableFuture.create(); in getStats()
96 SettableFuture<SocketStats> ret = SettableFuture.create(); in getStats()
131 SettableFuture<ServerStats> ret = SettableFuture.create(); in getStats()
165 SettableFuture<ChannelStats> ret = SettableFuture.create(); in getStats()
|
| /external/jimfs/jimfs/src/test/java/com/google/common/jimfs/ |
| D | JimfsAsynchronousFileChannelTest.java | 34 import com.google.common.util.concurrent.SettableFuture;
130 SettableFuture<Integer> completionHandlerFuture = SettableFuture.create(); in testAsyncClose_write()
164 SettableFuture<Integer> completionHandlerFuture = SettableFuture.create(); in testAsyncClose_read()
190 SettableFuture<Integer> future = SettableFuture.create(); in checkAsyncRead()
201 SettableFuture<Integer> future = SettableFuture.create(); in checkAsyncWrite()
211 SettableFuture<FileLock> future = SettableFuture.create(); in checkAsyncLock()
221 private static <T> CompletionHandler<T, Object> setFuture(final SettableFuture<T> future) { in setFuture()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/util/ |
| D | TransmitStatusRuntimeExceptionInterceptor.java | 20 import com.google.common.util.concurrent.SettableFuture;
178 final SettableFuture<Boolean> retVal = SettableFuture.create();
196 final SettableFuture<Boolean> retVal = SettableFuture.create();
234 final SettableFuture<Attributes> retVal = SettableFuture.create();
253 final SettableFuture<String> retVal = SettableFuture.create();
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | SettableFuture.java | 36 public final class SettableFuture<V> extends AbstractFuture.TrustedFuture<V> { class
40 public static <V> SettableFuture<V> create() { in create()
41 return new SettableFuture<V>(); in create()
62 private SettableFuture() {} in SettableFuture() method in SettableFuture
|
| /external/guava/android/guava/src/com/google/common/util/concurrent/ |
| D | SettableFuture.java | 36 public final class SettableFuture<V> extends AbstractFuture.TrustedFuture<V> { class
40 public static <V> SettableFuture<V> create() { in create()
41 return new SettableFuture<V>(); in create()
62 private SettableFuture() {} in SettableFuture() method in SettableFuture
|
| /external/guava/android/guava-testlib/test/com/google/common/testing/ |
| D | GcFinalizationTest.java | 22 import com.google.common.util.concurrent.SettableFuture;
57 final SettableFuture<Void> future = SettableFuture.create(); in testAwaitDone_Future()
72 final SettableFuture<Void> future = SettableFuture.create(); in testAwaitDone_Future_Cancel()
162 final SettableFuture<Void> future = SettableFuture.create(); in testAwaitDone_Future_Interrupted_Interrupted()
|
| /external/guava/guava-testlib/test/com/google/common/testing/ |
| D | GcFinalizationTest.java | 22 import com.google.common.util.concurrent.SettableFuture;
57 final SettableFuture<Void> future = SettableFuture.create(); in testAwaitDone_Future()
72 final SettableFuture<Void> future = SettableFuture.create(); in testAwaitDone_Future_Cancel()
164 final SettableFuture<Void> future = SettableFuture.create(); in testAwaitDone_Future_Interrupted_Interrupted()
|
| /external/downloader/src/main/java/com/google/android/downloader/ |
| D | CronetUrlEngine.java | 24 import com.google.common.util.concurrent.SettableFuture;
69 SettableFuture<UrlResponse> responseFuture = SettableFuture.create(); in createRequest()
137 private final SettableFuture<Long> completionFuture;
143 SettableFuture<Long> completionFuture, in CronetResponse()
181 private final SettableFuture<UrlResponse> responseFuture;
182 private final SettableFuture<Long> completionFuture = SettableFuture.create();
188 CronetCallback(SettableFuture<UrlResponse> responseFuture) { in CronetCallback()
|
| /external/caliper/caliper/src/main/java/com/google/caliper/runner/ |
| D | ServerSocketService.java | 29 import com.google.common.util.concurrent.SettableFuture;
100 private final Map<UUID, SettableFuture<OpenedSocket>> halfFinishedConnections = Maps.newHashMap();
176 private SettableFuture<OpenedSocket> getConnectionImpl(UUID id, Source source) { in getConnectionImpl()
181 SettableFuture<OpenedSocket> future = halfFinishedConnections.get(id); in getConnectionImpl()
183 future = SettableFuture.create(); in getConnectionImpl()
209 for (SettableFuture<OpenedSocket> future : halfFinishedConnections.values()) { in shutDown()
|
| /external/connectedappssdk/processor/src/main/resources/futurewrappers/ |
| D | ListenableFutureWrapper.java | 30 import com.google.common.util.concurrent.SettableFuture;
36 private final SettableFuture<E> future = SettableFuture.create();
105 SettableFuture<Map<Profile, E>> m = SettableFuture.create(); in groupResults()
|