| /external/guava/android/guava-tests/test/com/google/common/util/concurrent/ |
| D | AbstractAbstractFutureTest.java | 22 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
150 future.addListener(listener, directExecutor()); in testListenLaterSuccessful()
160 future.addListener(listener, directExecutor()); in testListenLaterFailed()
170 future.addListener(listener, directExecutor()); in testListenLaterCancelled()
180 future.addListener(listener, directExecutor()); in testListenLaterInterrupted()
190 future.addListener(listener, directExecutor()); in testListenLaterSetAsynchronously()
202 future.addListener(before, directExecutor()); in testListenLaterSetAsynchronouslyLaterDelegateSuccessful()
204 future.addListener(inBetween, directExecutor()); in testListenLaterSetAsynchronouslyLaterDelegateSuccessful()
206 future.addListener(after, directExecutor()); in testListenLaterSetAsynchronouslyLaterDelegateSuccessful()
218 future.addListener(before, directExecutor()); in testListenLaterSetAsynchronouslyLaterDelegateFailed()
[all …]
|
| D | ExecutionSequencerTest.java | 20 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
65 Future<?> possiblyIgnoredError = serializer.submitAsync(firstCallable, directExecutor()); in testCallableStartsAfterFirstFutureCompletes()
68 Future<?> possiblyIgnoredError1 = serializer.submitAsync(secondCallable, directExecutor()); in testCallableStartsAfterFirstFutureCompletes()
77 Future<?> possiblyIgnoredError = serializer.submitAsync(firstCallable, directExecutor()); in testCancellationDoesNotViolateSerialization()
79 ListenableFuture<Void> secondFuture = serializer.submitAsync(secondCallable, directExecutor()); in testCancellationDoesNotViolateSerialization()
82 Future<?> possiblyIgnoredError1 = serializer.submitAsync(thirdCallable, directExecutor()); in testCancellationDoesNotViolateSerialization()
102 directExecutor()); in testCancellationMultipleThreads()
129 directExecutor()); in testSecondTaskWaitsForFirstEvenIfCancelled()
165 directExecutor()); in testCancellationWithReferencedObject()
166 serializer.submit(toStringCallable(toBeGCed), directExecutor()).cancel(true); in testCancellationWithReferencedObject()
[all …]
|
| D | FutureCallbackTest.java | 21 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
41 addCallback(f, callback, directExecutor()); in testSameThreadSuccess()
59 addCallback(f, callback, directExecutor()); in testSameThreadExecutionException()
81 addCallback(f, callback, directExecutor()); in testCancel()
89 addCallback(f, callback, directExecutor()); in testThrowErrorFromGet()
96 addCallback(f, callback, directExecutor()); in testRuntimeExeceptionFromGet()
106 addCallback(future, callback, directExecutor()); in testOnSuccessThrowsRuntimeException()
122 addCallback(future, callback, directExecutor()); in testOnSuccessThrowsError()
146 addCallback(f, callback, directExecutor()); in testWildcardFuture()
|
| D | FuturesTest.java | 46 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
254 ListenableFuture<?> transformedFuture = transform(nullFuture, constant(null), directExecutor());
268 Bar bar = getDone(transform(future, function, directExecutor()));
285 ListenableFuture<Object> unused = transform(root, identity(), directExecutor());
292 output = transform(output, identity(), directExecutor());
314 ListenableFuture<Object> output = transform(input, transformer, directExecutor());
334 ListenableFuture<Object> output = transform(input, transformer, directExecutor());
345 ListenableFuture<Object> output = transform(input, identity(), directExecutor());
357 ListenableFuture<Object> output = transform(input, identity(), directExecutor());
368 ListenableFuture<Object> output = transform(input, identity(), directExecutor());
[all …]
|
| D | ExecutionListTest.java | 19 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
62 directExecutor()); in testExecute_idempotent()
85 directExecutor()); in testExecute_idempotentConcurrently()
125 MoreExecutors.directExecutor()); in testOrdering()
145 list.add(THROWING_RUNNABLE, directExecutor()); in testExceptionsCaught()
147 list.add(THROWING_RUNNABLE, directExecutor()); in testExceptionsCaught()
|
| D | FluentFutureTest.java | 23 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
73 directExecutor()); in testAddCallback()
88 directExecutor()); in testCatching()
103 directExecutor()); in testCatchingAsync()
117 directExecutor()); in testTransform()
131 directExecutor()); in testTransformAsync()
|
| D | JdkFutureAdaptersTest.java | 22 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
81 ExecutorSpy spy = new ExecutorSpy(directExecutor()); in testListenInPoolThreadIgnoresExecutorWhenDelegateIsDone()
93 listenableFuture.addListener(singleCallListener, directExecutor()); in testListenInPoolThreadIgnoresExecutorWhenDelegateIsDone()
151 listenableFuture.addListener(singleCallListener, directExecutor()); in testListenInPoolThreadCustomExecutorInterrupted()
254 listenable.addListener(earlyListener, directExecutor()); in testListenInPoolThreadRunsListenerAfterRuntimeException()
262 listenable.addListener(lateListener, directExecutor()); in testListenInPoolThreadRunsListenerAfterRuntimeException()
|
| D | ServiceManagerTest.java | 20 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
172 manager.addListener(listener, directExecutor()); in testServiceStartStop()
196 manager.addListener(listener, directExecutor()); in testFailStart()
220 manager.addListener(listener, directExecutor()); in testFailRun()
243 manager.addListener(listener, directExecutor()); in testFailStop()
293 manager.addListener(listener, directExecutor()); in testSingleFailedServiceCallsStopped()
310 manager.addListener(listener, directExecutor()); in testFailStart_singleServiceCallsHealthy()
336 directExecutor()); in testFailStart_stopOthers()
410 manager.addListener(listener, directExecutor()); in testEmptyServiceManager()
478 directExecutor()); in testListenerDeadlock()
|
| D | ListenerCallQueueTest.java | 19 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
54 queue.addListener(listener, directExecutor()); in testEnqueueAndDispatch()
69 queue.addListener(listener1, directExecutor()); in testEnqueueAndDispatch_multipleListeners()
76 queue.addListener(listener2, directExecutor()); in testEnqueueAndDispatch_multipleListeners()
87 queue.addListener(listener, directExecutor()); in testEnqueueAndDispatch_withExceptions()
113 queue.addListener(listener, directExecutor()); in testEnqueueAndDispatch_withLabeledExceptions()
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | AbstractAbstractFutureTest.java | 22 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
150 future.addListener(listener, directExecutor()); in testListenLaterSuccessful()
160 future.addListener(listener, directExecutor()); in testListenLaterFailed()
170 future.addListener(listener, directExecutor()); in testListenLaterCancelled()
180 future.addListener(listener, directExecutor()); in testListenLaterInterrupted()
190 future.addListener(listener, directExecutor()); in testListenLaterSetAsynchronously()
202 future.addListener(before, directExecutor()); in testListenLaterSetAsynchronouslyLaterDelegateSuccessful()
204 future.addListener(inBetween, directExecutor()); in testListenLaterSetAsynchronouslyLaterDelegateSuccessful()
206 future.addListener(after, directExecutor()); in testListenLaterSetAsynchronouslyLaterDelegateSuccessful()
218 future.addListener(before, directExecutor()); in testListenLaterSetAsynchronouslyLaterDelegateFailed()
[all …]
|
| D | ExecutionSequencerTest.java | 20 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
65 Future<?> possiblyIgnoredError = serializer.submitAsync(firstCallable, directExecutor()); in testCallableStartsAfterFirstFutureCompletes()
68 Future<?> possiblyIgnoredError1 = serializer.submitAsync(secondCallable, directExecutor()); in testCallableStartsAfterFirstFutureCompletes()
77 Future<?> possiblyIgnoredError = serializer.submitAsync(firstCallable, directExecutor()); in testCancellationDoesNotViolateSerialization()
79 ListenableFuture<Void> secondFuture = serializer.submitAsync(secondCallable, directExecutor()); in testCancellationDoesNotViolateSerialization()
82 Future<?> possiblyIgnoredError1 = serializer.submitAsync(thirdCallable, directExecutor()); in testCancellationDoesNotViolateSerialization()
102 directExecutor()); in testCancellationMultipleThreads()
129 directExecutor()); in testSecondTaskWaitsForFirstEvenIfCancelled()
165 directExecutor()); in testCancellationWithReferencedObject()
166 serializer.submit(toStringCallable(toBeGCed), directExecutor()).cancel(true); in testCancellationWithReferencedObject()
[all …]
|
| D | FutureCallbackTest.java | 21 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
41 addCallback(f, callback, directExecutor()); in testSameThreadSuccess()
59 addCallback(f, callback, directExecutor()); in testSameThreadExecutionException()
81 addCallback(f, callback, directExecutor()); in testCancel()
89 addCallback(f, callback, directExecutor()); in testThrowErrorFromGet()
96 addCallback(f, callback, directExecutor()); in testRuntimeExeceptionFromGet()
106 addCallback(future, callback, directExecutor()); in testOnSuccessThrowsRuntimeException()
122 addCallback(future, callback, directExecutor()); in testOnSuccessThrowsError()
146 addCallback(f, callback, directExecutor()); in testWildcardFuture()
|
| D | FuturesTest.java | 46 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
254 ListenableFuture<?> transformedFuture = transform(nullFuture, constant(null), directExecutor());
268 Bar bar = getDone(transform(future, function, directExecutor()));
285 ListenableFuture<Object> unused = transform(root, identity(), directExecutor());
292 output = transform(output, identity(), directExecutor());
314 ListenableFuture<Object> output = transform(input, transformer, directExecutor());
334 ListenableFuture<Object> output = transform(input, transformer, directExecutor());
345 ListenableFuture<Object> output = transform(input, identity(), directExecutor());
357 ListenableFuture<Object> output = transform(input, identity(), directExecutor());
368 ListenableFuture<Object> output = transform(input, identity(), directExecutor());
[all …]
|
| D | ExecutionListTest.java | 19 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
62 directExecutor()); in testExecute_idempotent()
85 directExecutor()); in testExecute_idempotentConcurrently()
125 MoreExecutors.directExecutor()); in testOrdering()
145 list.add(THROWING_RUNNABLE, directExecutor()); in testExceptionsCaught()
147 list.add(THROWING_RUNNABLE, directExecutor()); in testExceptionsCaught()
|
| D | FluentFutureTest.java | 23 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
73 directExecutor()); in testAddCallback()
88 directExecutor()); in testCatching()
103 directExecutor()); in testCatchingAsync()
117 directExecutor()); in testTransform()
131 directExecutor()); in testTransformAsync()
|
| D | JdkFutureAdaptersTest.java | 22 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
81 ExecutorSpy spy = new ExecutorSpy(directExecutor()); in testListenInPoolThreadIgnoresExecutorWhenDelegateIsDone()
93 listenableFuture.addListener(singleCallListener, directExecutor()); in testListenInPoolThreadIgnoresExecutorWhenDelegateIsDone()
151 listenableFuture.addListener(singleCallListener, directExecutor()); in testListenInPoolThreadCustomExecutorInterrupted()
254 listenable.addListener(earlyListener, directExecutor()); in testListenInPoolThreadRunsListenerAfterRuntimeException()
262 listenable.addListener(lateListener, directExecutor()); in testListenInPoolThreadRunsListenerAfterRuntimeException()
|
| D | ListenerCallQueueTest.java | 19 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
54 queue.addListener(listener, directExecutor()); in testEnqueueAndDispatch()
69 queue.addListener(listener1, directExecutor()); in testEnqueueAndDispatch_multipleListeners()
76 queue.addListener(listener2, directExecutor()); in testEnqueueAndDispatch_multipleListeners()
87 queue.addListener(listener, directExecutor()); in testEnqueueAndDispatch_withExceptions()
113 queue.addListener(listener, directExecutor()); in testEnqueueAndDispatch_withLabeledExceptions()
|
| /external/robolectric/robolectric/src/test/java/org/robolectric/shadows/ |
| D | ShadowBugreportManagerTest.java | 5 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
72 directExecutor(), in startBugreport()
94 directExecutor(), in startBugreport_noPermission()
110 directExecutor(), in startTwoBugreports()
123 directExecutor(), in startTwoBugreports()
147 directExecutor(), in cancelBugreport()
169 directExecutor(), in cancelBugreport_noPermission()
192 directExecutor(), in executeOnError()
214 directExecutor(), in executeOnFinished()
242 directExecutor(), in executeOnProgress()
[all …]
|
| D | ShadowAmbientContextManagerTest.java | 60 MoreExecutors.directExecutor(), in registerObserver_shouldStoreLastRequest()
86 MoreExecutors.directExecutor(), in registerObserver_thenUnregister_shouldClearLastRequest()
117 request, pendingIntent, MoreExecutors.directExecutor(), statusFuture::set); in registerObserver_statusSetToSuccess_shouldNotifyConsumerWithStoredStatus()
133 MoreExecutors.directExecutor(), in queryAmbientContextServiceStatus_statusSetToSuccess_shouldReturnSuccess()
150 MoreExecutors.directExecutor(), in queryAmbientContextServiceStatus_statusSetToNotSupported_shouldReturnNotSupported()
|
| /external/dagger2/java/dagger/producers/internal/ |
| D | Producers.java | 22 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
55 transform(future, Producers.<T>resultToProduced(), directExecutor()), in createFutureProduced()
58 directExecutor()); in createFutureProduced()
101 directExecutor()); in createFutureSingletonSet() method
120 directExecutor());
|
| D | DependencyMethodProducer.java | 19 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
67 directExecutor()); in get()
113 directExecutor()); in newEntryPointView()
|
| /external/opencensus-java/contrib/agent/src/jmh/java/io/opencensus/contrib/agent/instrumentation/ |
| D | ExecutorInstrumentationBenchmark.java | 56 MoreExecutors.directExecutor().execute(new MyRunnable(blackhole)); in none()
69 MoreExecutors.directExecutor().execute(Context.current().wrap(new MyRunnable(blackhole))); in manual()
82 MoreExecutors.directExecutor().execute(new MyRunnable(blackhole)); in automatic()
|
| /external/connectedappssdk/processor/src/main/resources/futurewrappers/ |
| D | ListenableFutureWrapper.java | 18 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
75 directExecutor()); in writeFutureResult()
117 directExecutor()) in groupResults()
118 .addCallback(new MergerFutureCallback<>(result.getKey(), merger), directExecutor()); in groupResults()
|
| /external/mobile-data-download/java/com/google/android/libraries/mobiledatadownload/internal/logging/ |
| D | MddEventLogger.java | 19 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
165 directExecutor()), in logMddFileGroupStats() method in MddEventLogger
179 directExecutor()), in logMddStorageStats()
189 buildNetworkStats.call(), networkStats -> Arrays.asList(), directExecutor()), in logMddNetworkStats()
306 directExecutor()); in lazySampleAndSendLogEvent()
308 directExecutor()); in lazySampleAndSendLogEvent()
330 directExecutor());
|
| /external/grpc-grpc-java/testing/src/main/java/io/grpc/testing/ |
| D | GrpcServerRule.java | 56 public final GrpcServerRule directExecutor() { in directExecutor() method in GrpcServerRule
130 serverBuilder.directExecutor(); in before()
138 channelBuilder.directExecutor(); in before()
|