Home
last modified time | relevance | path

Searched refs:mLightWeightExecutor (Results 1 – 4 of 4) sorted by relevance

/packages/modules/AdServices/shared/tests/device-side/java/com/android/adservices/shared/testing/common/
DBlockingCallableWrapperTest.java48 private final ListeningExecutorService mLightWeightExecutor = sLightWeightExecutor; field in BlockingCallableWrapperTest
55 ListenableFuture<Integer> asyncWork = mLightWeightExecutor.submit(toTest); in testRunsDelegate()
65 ListenableFuture<Integer> asyncWork = mLightWeightExecutor.submit(toTest); in testMarksTaskAsCompleted()
89 ListenableFuture<Integer> asyncWork = mLightWeightExecutor.submit(toTest); in testCommandExecutionDoesNotStartsIfNotTriggered()
106 ListenableFuture<Integer> asyncWork = mLightWeightExecutor.submit(toTest); in testCommandExecutionStartsWhenTriggered()
128 ListenableFuture<Integer> asyncWork = mLightWeightExecutor.submit(toTest); in testBlocksCallerUntilCompleted()
144 ListenableFuture<Integer> asyncWork = mLightWeightExecutor.submit(toTest); in testBlocksCallerUntilTimeoutIfNotCompleted()
/packages/modules/AdServices/adservices/service-core/java/com/android/adservices/service/customaudience/
DScheduledUpdatesHandler.java99 @NonNull private final ListeningExecutorService mLightWeightExecutor; field in ScheduledUpdatesHandler
136 mLightWeightExecutor = lightWeightExecutor; in ScheduledUpdatesHandler()
224 return scheduledUpdates.transformAsync(su -> handleUpdates(su), mLightWeightExecutor); in performScheduledUpdates()
242 .transform(ignored -> null, mLightWeightExecutor); in handleUpdates()
314 mLightWeightExecutor); in fetchUpdate()
342 mLightWeightExecutor) in parseFetchUpdateResponse()
343 .transformAsync(ignoredVoid -> removeHandledUpdate(update), mLightWeightExecutor); in parseFetchUpdateResponse()
359 .transformAsync(ignored -> null, mLightWeightExecutor); in removeHandledUpdate()
410 .transform(ignored -> null, mLightWeightExecutor); in joinCustomAudiences()
476 .transform(ignored -> null, mLightWeightExecutor); in persistCustomAudience()
/packages/modules/AdServices/adservices/service-core/java/com/android/adservices/service/signals/
DPeriodicEncodingJobWorker.java93 private final ListeningExecutorService mLightWeightExecutor; field in PeriodicEncodingJobWorker
123 mLightWeightExecutor = lightWeightExecutor; in PeriodicEncodingJobWorker()
235 mLightWeightExecutor); in doRun() field in PeriodicEncodingJobWorker
254 .transform(ignored -> null, mLightWeightExecutor); in doEncodingForRegisteredBuyers()
277 mLightWeightExecutor); in pickLoggerAndRunEncodingPerBuyer()
290 .transform(ignored -> null, mLightWeightExecutor);
357 mLightWeightExecutor)
/packages/modules/AdServices/adservices/tests/unittest/service-core/src/com/android/adservices/service/signals/
DPeriodicEncodingJobWorkerTest.java141 private ListeningExecutorService mLightWeightExecutor = field in PeriodicEncodingJobWorkerTest
168 mLightWeightExecutor, in setup()
204 mLightWeightExecutor, in testValidateAndPersistLargePayloadSkips()