| /aosp_15_r20/external/guava/guava/src/com/google/common/util/concurrent/ |
| H A D | ClosingFuture.java | 515 ClosingFuture<?> future1, ClosingFuture<?>... moreFutures) { in whenAllComplete()
541 Combiner2<V1, V2> whenAllSucceed(ClosingFuture<V1> future1, ClosingFuture<V2> future2) { in whenAllSucceed()
558 ClosingFuture<V1> future1, ClosingFuture<V2> future2, ClosingFuture<V3> future3) { in whenAllSucceed()
578 ClosingFuture<V1> future1, in whenAllSucceed()
602 ClosingFuture<V1> future1, in whenAllSucceed()
618 ClosingFuture<?> future1, in whenAllSucceed()
|
| /aosp_15_r20/external/guava/android/guava/src/com/google/common/util/concurrent/ |
| H A D | ClosingFuture.java | 510 ClosingFuture<?> future1, ClosingFuture<?>... moreFutures) { in whenAllComplete()
536 Combiner2<V1, V2> whenAllSucceed(ClosingFuture<V1> future1, ClosingFuture<V2> future2) { in whenAllSucceed()
553 ClosingFuture<V1> future1, ClosingFuture<V2> future2, ClosingFuture<V3> future3) { in whenAllSucceed()
573 ClosingFuture<V1> future1, in whenAllSucceed()
597 ClosingFuture<V1> future1, in whenAllSucceed()
613 ClosingFuture<?> future1, in whenAllSucceed()
|
| /aosp_15_r20/frameworks/base/core/tests/coretests/src/com/android/internal/infra/ |
| H A D | AndroidFutureTest.java | 105 AndroidFuture<Integer> future1 = new AndroidFuture<>(); in testWriteToParcel() local
117 AndroidFuture<Integer> future1 = new AndroidFuture<>(); in testWriteToParcel_Exception() local
136 AndroidFuture<Integer> future1 = new AndroidFuture<>(); in testWriteToParcel_Incomplete() local
148 AndroidFuture<Integer> future1 = new AndroidFuture<>(); in testWriteToParcel_Incomplete_Exception() local
|
| /aosp_15_r20/external/rust/android-crates-io/crates/futures/tests/ |
| D | macro_comma_support.rs | 29 let future1 = async { 1 }; in join() localVariable
38 let future1 = async { 1 }.never_error(); in try_join() localVariable
|
| D | try_join.rs | 20 let future1 = async { Ok::<(), Never>(()) }; in try_join_never_error() localVariable
30 let future1 = async { Err::<Never, ()>(()) }; in try_join_never_ok() localVariable
|
| D | future_shared.rs | 88 let future1 = future::lazy(move |_| { in drop_in_poll() localVariable
|
| /aosp_15_r20/external/sdk-platform-java/gax-java/gax/src/test/java/com/google/api/gax/rpc/ |
| H A D | BatchingCallableTest.java | 91 ApiFuture<List<Integer>> future1 = in testBatchedCall() local
130 ApiFuture<List<Integer>> future1 = in testUnbatchedCall() local
|
| /aosp_15_r20/packages/modules/Bluetooth/system/gd/hci/ |
| D | remote_name_request_test.cc | 398 auto future1 = promise1.get_future(); in TEST_F() local
477 auto future1 = promise1.get_future(); in TEST_F() local
522 auto future1 = promise1.get_future(); in TEST_F() local
|
| /aosp_15_r20/art/libartservice/service/javatests/com/android/server/art/ |
| H A D | BackgroundDexoptJobTest.java | 148 Future<Result> future1 = mBackgroundDexoptJob.start(); in testStartAlreadyRunning() local
163 Future<Result> future1 = mBackgroundDexoptJob.start(); in testStartAnother() local
|
| /aosp_15_r20/external/connectedappssdk/tests/robotests/src/test/java/com/google/android/enterprise/connectedapps/internal/ |
| H A D | CrossProfileCallbackMultiMergerTest.java | 214 ListenableFuture<String> future1 = Futures.submit(() -> "Hello", executorWithThread1); in listenableFuturesCompletingOnSeparateThreads() local
240 ListenableFuture<String> future1 = Futures.submit(() -> "Hello", executorWithThread1); in listenableFuturesCompletingWithErrorsOnSeparateThreads() local
|
| /aosp_15_r20/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| H A D | NettyClientHandlerTest.java | 431 ChannelFuture future1 = writeQueue().enqueue( in receivedGoAway_shouldFailBufferedStreamsExceedingMaxConcurrentStreams() local
710 ChannelFuture future1 = createStream(); in nonExistentStream() local
|
| /aosp_15_r20/external/sdv/vsomeip/third_party/boost/thread/test/ |
| D | test_12293.cpp | 30 auto future1 = promise1.get_future(); in main() local
|
| /aosp_15_r20/external/opencensus-java/examples/spring/servlet/src/main/java/io/opencensus/examples/spring/servlet/ |
| H A D | HelloController.java | 49 ListenableFuture<ResponseEntity<String>> future1 = in index() local
|
| /aosp_15_r20/frameworks/base/services/tests/powerstatstests/src/com/android/server/power/stats/ |
| H A D | PowerStatsCollectorTest.java | 151 CompletableFuture<EnergyConsumerResult[]> future1 = mock(CompletableFuture.class); in mockEnergyConsumers() local
|
| /aosp_15_r20/external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| H A D | ExecutionSequencerTest.java | 123 ListenableFuture<@Nullable Void> future1 = serializer.submit(blockingCallable, executor); in testSecondTaskWaitsForFirstEvenIfCancelled() local
|
| /aosp_15_r20/external/guava/android/guava-tests/test/com/google/common/util/concurrent/ |
| H A D | ExecutionSequencerTest.java | 123 ListenableFuture<@Nullable Void> future1 = serializer.submit(blockingCallable, executor); in testSecondTaskWaitsForFirstEvenIfCancelled() local
|
| /aosp_15_r20/external/aws-sdk-java-v2/test/codegen-generated-classes-test/src/test/java/software/amazon/awssdk/services/waiters/ |
| H A D | WaitersAsyncFunctionalTest.java | 159 CompletableFuture<AllTypesResponse> future1 = in unexpectedResponse_shouldRetry() local
|
| /aosp_15_r20/packages/modules/Connectivity/remoteauth/tests/unit/src/com/android/server/remoteauth/connectivity/ |
| D | CdmConnectivityManagerTest.java | 195 SettableFuture<Boolean> future1 = SettableFuture.create(); in testMultipleStartDiscovery_runsAllCallbacks() local
|
| /aosp_15_r20/hardware/interfaces/biometrics/common/thread/tests/ |
| H A D | WorkerThreadTest.cpp | 105 auto future1 = promise1.get_future(); in TEST() local
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tokio/tests/ |
| D | sync_notify.rs | 280 let mut future1 = spawn(notify.notified()); in test_enable_consumes_permit() localVariable
|
| /aosp_15_r20/packages/modules/Bluetooth/system/gd/hci/acl_manager/ |
| D | acl_scheduler_test.cc | 119 auto future1 = promise1.get_future(); in TEST_F() local
|
| /aosp_15_r20/packages/modules/Bluetooth/system/stack/a2dp/ |
| D | a2dp_vendor_aptx.cc | 56 uint8_t future1; member
|
| D | a2dp_vendor_opus.cc | 57 uint8_t future1; /* codec_specific_1 framesize */ member
|
| /aosp_15_r20/external/conscrypt/repackaged/common/src/test/java/com/android/org/conscrypt/javax/net/ssl/ |
| H A D | SSLSocketVersionCompatibilityTest.java | 234 final Future<byte[]> future1 = runAsync(new SSLServerSessionIdCallable(server1)); in test_SSLSocket_confirmSessionReuse() local
|
| /aosp_15_r20/external/conscrypt/common/src/test/java/org/conscrypt/javax/net/ssl/ |
| H A D | SSLSocketVersionCompatibilityTest.java | 228 final Future<byte[]> future1 = runAsync(new SSLServerSessionIdCallable(server1)); in test_SSLSocket_confirmSessionReuse() local
|