Home
last modified time | relevance | path

Searched refs:SettableFuture (Results 1 – 25 of 27) sorted by relevance

12

/cts/tests/appsearch/testutils/src/android/app/appsearch/testutil/
DAppSearchSessionShimImpl.java49 import com.google.common.util.concurrent.SettableFuture;
90 SettableFuture<AppSearchResult<AppSearchSession>> future = SettableFuture.create(); in createSearchSessionAsync()
107 SettableFuture<AppSearchResult<SetSchemaResponse>> future = SettableFuture.create(); in setSchemaAsync()
115 SettableFuture<AppSearchResult<GetSchemaResponse>> future = SettableFuture.create(); in getSchemaAsync()
123 SettableFuture<AppSearchResult<Set<String>>> future = SettableFuture.create(); in getNamespacesAsync()
132 SettableFuture<AppSearchBatchResult<String, Void>> future = SettableFuture.create(); in putAsync()
142 SettableFuture<AppSearchBatchResult<String, GenericDocument>> future = in getByDocumentIdAsync()
143 SettableFuture.create(); in getByDocumentIdAsync()
160 SettableFuture<AppSearchResult<Void>> future = SettableFuture.create(); in reportUsageAsync()
169 SettableFuture<AppSearchBatchResult<String, Void>> future = SettableFuture.create(); in removeAsync()
[all …]
DGlobalSearchSessionShimImpl.java42 import com.google.common.util.concurrent.SettableFuture;
72 SettableFuture<AppSearchResult<GlobalSearchSession>> future = SettableFuture.create(); in createGlobalSearchSessionAsync()
93 SettableFuture<AppSearchBatchResult<String, GenericDocument>> future = in getByDocumentIdAsync()
94 SettableFuture.create(); in getByDocumentIdAsync()
113 SettableFuture<AppSearchResult<Void>> future = SettableFuture.create(); in reportSystemUsageAsync()
122 SettableFuture<AppSearchResult<GetSchemaResponse>> future = SettableFuture.create(); in getSchemaAsync()
DEnterpriseGlobalSearchSessionShimImpl.java39 import com.google.common.util.concurrent.SettableFuture;
68 SettableFuture<AppSearchResult<EnterpriseGlobalSearchSession>> future = SettableFuture in createEnterpriseGlobalSearchSessionAsync()
99 SettableFuture<AppSearchBatchResult<String, GenericDocument>> future =
100 SettableFuture.create();
120 SettableFuture<AppSearchResult<GetSchemaResponse>> future = SettableFuture.create();
DBatchResultCallbackAdapter.java22 import com.google.common.util.concurrent.SettableFuture;
26 private final SettableFuture<AppSearchBatchResult<K, V>> mFuture;
28 BatchResultCallbackAdapter(SettableFuture<AppSearchBatchResult<K, V>> future) { in BatchResultCallbackAdapter()
DSearchResultsShimImpl.java28 import com.google.common.util.concurrent.SettableFuture;
53 SettableFuture<AppSearchResult<List<SearchResult>>> future = SettableFuture.create(); in getNextPageAsync()
/cts/tests/tests/soundtrigger/src/android/soundtrigger/cts/instrumentation/
DSoundTriggerInstrumentationObserver.java36 import com.google.common.util.concurrent.SettableFuture;
76 private SettableFuture<RecognitionSession> mOnRecognitionStarted = SettableFuture.create();
79 private SettableFuture<Void> mOnRecognitionStopped = SettableFuture.create();
82 private SettableFuture<Void> mOnModelUnloaded = SettableFuture.create();
159 mOnRecognitionStarted = SettableFuture.create(); in resetOnRecognitionStartedFuture()
171 mOnRecognitionStopped = SettableFuture.create(); in resetOnRecognitionStoppedFuture()
183 mOnModelUnloaded = SettableFuture.create(); in resetOnModelUnloadedFuture()
206 private SettableFuture<ModelSessionObserver> mOnModelLoaded = SettableFuture.create();
209 private SettableFuture<Void> mOnClientAttached = SettableFuture.create();
212 private SettableFuture<Void> mOnClientDetached = SettableFuture.create();
[all …]
/cts/libs/deviceutillegacy/src/android/webkit/cts/
DWebkitUtils.java22 import com.google.common.util.concurrent.SettableFuture;
61 final SettableFuture<T> future = SettableFuture.create(); in onMainThread()
116 final SettableFuture<Void> exceptionPropagatingFuture = SettableFuture.create(); in onMainThreadSync()
DWebViewOnUiThread.java48 import com.google.common.util.concurrent.SettableFuture;
489 final SettableFuture<String> future = SettableFuture.create();
567 final SettableFuture<Void> future = SettableFuture.create();
/cts/tests/tests/security/src/android/security/cts/
DAttributionSourceService.java113 private static class SettableFuture<T> extends FutureTask<T> { class in AttributionSourceService
115 SettableFuture() { in SettableFuture() method in AttributionSourceService.SettableFuture
125 SettableFuture(Callable<T> callable) { in SettableFuture() method in AttributionSourceService.SettableFuture
129 SettableFuture(Runnable runnable, T result) { in SettableFuture() method in AttributionSourceService.SettableFuture
157 private final LinkedBlockingQueue<SettableFuture<Byte>> mFuturesQueue =
169 public void addFuture(SettableFuture<Byte> report) { in addFuture()
181 SettableFuture<Byte> task = mFuturesQueue.poll(); in handleMessage()
285 SettableFuture<Byte> task = new SettableFuture<>(); in postAttributionSource()
/cts/tests/tests/webkit/src/android/webkit/cts/
DTestProcessService.java26 import com.google.common.util.concurrent.SettableFuture;
43 final SettableFuture<Bundle> testResultFuture = SettableFuture.create();
DWebViewRenderProcessTest.java37 import com.google.common.util.concurrent.SettableFuture;
108 final SettableFuture<WebViewRenderProcess> future = SettableFuture.create();
125 final SettableFuture<Boolean> future = SettableFuture.create();
DWebViewRenderProcessClientTest.java36 import com.google.common.util.concurrent.SettableFuture;
99 private SettableFuture<Void> mIsBlocked;
103 mIsBlocked = SettableFuture.create(); in JSBlocker()
160 final SettableFuture<Void> rendererUnblocked = SettableFuture.create(); in testWebViewRenderProcessClientOnExecutor()
DTestProcessClient.java32 import com.google.common.util.concurrent.SettableFuture;
80 final SettableFuture<Void> exceptionPropagatingFuture = SettableFuture.create(); in run()
DPostMessageTest.java37 import com.google.common.util.concurrent.SettableFuture;
312 final SettableFuture<Boolean> messageHandlerThreadFuture = SettableFuture.create(); in testWebMessageHandler()
346 final SettableFuture<Boolean> messageMainLooperFuture = SettableFuture.create(); in testWebMessageDefaultHandler()
DWebViewStartupTest.java37 import com.google.common.util.concurrent.SettableFuture;
202 final SettableFuture<WebView> webViewFuture = SettableFuture.create(); in run()
DWebViewTest.java88 import com.google.common.util.concurrent.SettableFuture;
805 final SettableFuture<Void> onCreateWindowFuture = SettableFuture.create(); in testJavascriptInterfaceForClientPopup()
1318 private final SettableFuture<Integer> mFuture;
1325 mFuture = SettableFuture.create(); in WaitForFindResultsListener()
1448 private SettableFuture<Integer> mFuture; in testDocumentHasImages()
1452 mFuture = SettableFuture.create(); in testDocumentHasImages()
1785 public SettableFuture<Void> mImageLoaded = SettableFuture.create(); in testRequestImageRef()
2115 final SettableFuture<Void> downloadStartFuture = SettableFuture.create(); in testSetDownloadListener()
2215 final SettableFuture<Void> future = SettableFuture.create(); in testSetWebChromeClient()
2350 final SettableFuture<Void> result = SettableFuture.create(); in testPrinting()
[all …]
DWebChromeClientTest.java46 import com.google.common.util.concurrent.SettableFuture;
247 final SettableFuture<Void> onJsBeforeUnloadFuture = SettableFuture.create(); in testOnJsBeforeUnloadIsCalled()
/cts/tests/camera/src/android/hardware/multiprocess/camera/cts/
DErrorLoggingService.java305 private static class SettableFuture<T> extends FutureTask<T> { class in ErrorLoggingService
307 public SettableFuture() { in SettableFuture() method in ErrorLoggingService.SettableFuture
317 public SettableFuture(Callable<T> callable) { in SettableFuture() method in ErrorLoggingService.SettableFuture
321 public SettableFuture(Runnable runnable, T result) { in SettableFuture() method in ErrorLoggingService.SettableFuture
375 private final LinkedBlockingQueue<SettableFuture<List<LogEvent>>> mFuturesQueue =
386 List<SettableFuture<List<LogEvent>>> logFutures = new ArrayList<>(); in cancelAll()
388 for (SettableFuture<List<LogEvent>> i : logFutures) { in cancelAll()
398 public void cancel(SettableFuture<List<LogEvent>> report) { in cancel()
408 public void addFuture(SettableFuture<List<LogEvent>> report) { in addFuture()
419 SettableFuture<List<LogEvent>> task = mFuturesQueue.poll(); in handleMessage()
[all …]
/cts/tests/tests/virtualdevice/audio/src/android/virtualdevice/cts/audio/
DTextToSpeechTest.java48 import com.google.common.util.concurrent.SettableFuture;
154 SettableFuture<Integer> ttsInitFuture = SettableFuture.create(); in initializeTextToSpeech()
177 private final SettableFuture<AudioPlaybackConfiguration> mAudioPlaybackConfigurationFuture =
178 SettableFuture.create();
/cts/tests/inputmethod/util/src/android/view/inputmethod/cts/util/
DTestActivity.java50 import com.google.common.util.concurrent.SettableFuture;
66 private static final AtomicReference<SettableFuture<TestActivity>> sFutureRef =
118 final SettableFuture<TestActivity> future = sFutureRef.getAndSet(null); in onEnterAnimationComplete()
390 final SettableFuture<TestActivity> future = SettableFuture.create(); in startSync()
/cts/tests/tests/speech/src/android/speech/tts/cts/
DTextToSpeechServiceTest.java32 import com.google.common.util.concurrent.SettableFuture;
77 final SettableFuture<String> errorMsg = SettableFuture.create(); in testNullEngine()
78 final SettableFuture<Void> connected = SettableFuture.create(); in testNullEngine()
79 final SettableFuture<Void> disconnected = SettableFuture.create(); in testNullEngine()
/cts/tests/tests/soundtrigger/src/android/soundtrigger/cts/
DSoundTriggerManagerTest.java56 import com.google.common.util.concurrent.SettableFuture;
89 private SettableFuture<Void> mDetectedFuture;
153 mDetectedFuture = SettableFuture.create(); in listenForDetection()
251 final SettableFuture<Void> ambientOpFuture = SettableFuture.create(); in testRecognitionEvent_notesAppOps()
/cts/tests/tests/text/src/android/text/cts/
DEmojiTest.java48 import com.google.common.util.concurrent.SettableFuture;
320 final SettableFuture<Void> future = SettableFuture.create(); in capture()
/cts/tests/tests/netsecpolicy/src/android/security/
DNetworkSecurityPolicyTestBase.java219 … final SettableFuture<Intent> downloadCompleteIntentFuture = new SettableFuture<Intent>(); in downloadUsingDownloadManager()
280 private static class SettableFuture<T> implements Future<T> { class in NetworkSecurityPolicyTestBase
/cts/tests/tests/voiceinteraction/src/android/voiceinteraction/cts/
DAlwaysOnHotwordDetectorTest.java80 import com.google.common.util.concurrent.SettableFuture;
877 final SettableFuture<String> appOpFuture = SettableFuture.create(); in testOnDetected_appropriateAppOpsNoted()
923 final SettableFuture<String> appOpFuture = SettableFuture.create(); in testOnRejected_noAppOpsNoted()

12