| /aosp_15_r20/external/guava/guava/src/com/google/common/util/concurrent/ |
| H A D | ClosingFuture.java | 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()
579 ClosingFuture<V2> future2, in whenAllSucceed()
603 ClosingFuture<V2> future2, in whenAllSucceed()
619 ClosingFuture<?> future2, in whenAllSucceed()
|
| /aosp_15_r20/external/guava/android/guava/src/com/google/common/util/concurrent/ |
| H A D | ClosingFuture.java | 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()
574 ClosingFuture<V2> future2, in whenAllSucceed()
598 ClosingFuture<V2> future2, in whenAllSucceed()
614 ClosingFuture<?> future2, in whenAllSucceed()
|
| /aosp_15_r20/frameworks/base/core/tests/coretests/src/com/android/internal/infra/ |
| H A D | AndroidFutureTest.java | 110 AndroidFuture future2 = AndroidFuture.CREATOR.createFromParcel(parcel); in testWriteToParcel() local
122 AndroidFuture future2 = AndroidFuture.CREATOR.createFromParcel(parcel); in testWriteToParcel_Exception() local
140 AndroidFuture future2 = AndroidFuture.CREATOR.createFromParcel(parcel); in testWriteToParcel_Incomplete() local
152 AndroidFuture future2 = AndroidFuture.CREATOR.createFromParcel(parcel); in testWriteToParcel_Incomplete_Exception() local
|
| /aosp_15_r20/packages/modules/Bluetooth/system/gd/hci/ |
| D | remote_name_request_test.cc | 400 auto future2 = promise2.get_future(); in TEST_F() local
479 auto future2 = promise2.get_future(); in TEST_F() local
524 auto future2 = promise2.get_future(); in TEST_F() local
648 auto future2 = promise2.get_future(); in TEST_F() local
|
| /aosp_15_r20/external/rust/android-crates-io/crates/futures/tests/ |
| D | macro_comma_support.rs | 30 let future2 = async { 2 }; in join() localVariable
39 let future2 = async { 2 }.never_error(); in try_join() localVariable
|
| D | try_join.rs | 21 let future2 = async { Ok::<(), Never>(()) }; in try_join_never_error() localVariable
31 let future2 = async { Err::<Never, ()>(()) }; in try_join_never_ok() localVariable
|
| D | future_shared.rs | 94 let future2 = LocalFutureObj::new(Box::new(future1.clone())); in drop_in_poll() localVariable
|
| /aosp_15_r20/external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| H A D | ExecutionSequencerTest.java | 97 ListenableFuture<Boolean> future2 = in testCancellationMultipleThreads() local
124 ListenableFuture<Boolean> future2 = in testSecondTaskWaitsForFirstEvenIfCancelled() local
|
| /aosp_15_r20/external/guava/android/guava-tests/test/com/google/common/util/concurrent/ |
| H A D | ExecutionSequencerTest.java | 97 ListenableFuture<Boolean> future2 = in testCancellationMultipleThreads() local
124 ListenableFuture<Boolean> future2 = in testSecondTaskWaitsForFirstEvenIfCancelled() local
|
| /aosp_15_r20/art/libartservice/service/javatests/com/android/server/art/ |
| H A D | BackgroundDexoptJobTest.java | 149 Future<Result> future2 = mBackgroundDexoptJob.start(); in testStartAlreadyRunning() local
165 Future<Result> future2 = mBackgroundDexoptJob.start(); in testStartAnother() local
|
| /aosp_15_r20/frameworks/base/services/tests/vibrator/src/com/android/server/vibrator/ |
| H A D | VibratorControlServiceTest.java | 336 CompletableFuture<Void> future2 = in testRequestVibrationParams_withOngoingRequestAndSameUsage_returnOngoingFuture() local
355 CompletableFuture<Void> future2 = in testRequestVibrationParams_withOngoingRequestAndSameUsage_returnNewFuture() local
|
| /aosp_15_r20/external/connectedappssdk/tests/robotests/src/test/java/com/google/android/enterprise/connectedapps/internal/ |
| H A D | CrossProfileCallbackMultiMergerTest.java | 215 ListenableFuture<String> future2 = Futures.submit(() -> "World", executorWithThread2); in listenableFuturesCompletingOnSeparateThreads() local
241 ListenableFuture<String> future2 = in listenableFuturesCompletingWithErrorsOnSeparateThreads() local
|
| /aosp_15_r20/frameworks/base/tests/AttestationVerificationTest/src/android/security/attestationverification/ |
| H A D | PeerDeviceSystemAttestationVerificationTest.kt | 86 val future2 = CompletableFuture<Int>() in <lambda>() constant
|
| /aosp_15_r20/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| H A D | NettyClientHandlerTest.java | 433 ChannelFuture future2 = writeQueue().enqueue( in receivedGoAway_shouldFailBufferedStreamsExceedingMaxConcurrentStreams() local
715 ChannelFuture future2 = enqueue(new CancelClientStreamCommand(streamTransportState, status)); in nonExistentStream() local
|
| /aosp_15_r20/packages/modules/AppSearch/testing/coretests/src/android/app/appsearch/ |
| D | GlobalSearchSessionUnitTest.java | 70 CompletableFuture<AppSearchResult<AppSearchSession>> future2 = new CompletableFuture<>(); in setUp() local
|
| /aosp_15_r20/external/opencensus-java/examples/spring/servlet/src/main/java/io/opencensus/examples/spring/servlet/ |
| H A D | HelloController.java | 51 ListenableFuture<ResponseEntity<String>> future2 = in index() local
|
| /aosp_15_r20/frameworks/base/services/tests/powerstatstests/src/com/android/server/power/stats/ |
| H A D | PowerStatsCollectorTest.java | 164 CompletableFuture<EnergyConsumerResult[]> future2 = mock(CompletableFuture.class); in mockEnergyConsumers() local
|
| /aosp_15_r20/external/sdk-platform-java/gax-java/gax/src/test/java/com/google/api/gax/rpc/ |
| H A D | BatchingCallableTest.java | 97 ApiFuture<List<Integer>> future2 = in testBatchedCall() 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 | 165 CompletableFuture<AllTypesResponse> future2 = in unexpectedResponse_shouldRetry() local
|
| /aosp_15_r20/packages/modules/Connectivity/remoteauth/tests/unit/src/com/android/server/remoteauth/connectivity/ |
| D | CdmConnectivityManagerTest.java | 196 SettableFuture<Boolean> future2 = SettableFuture.create(); in testMultipleStartDiscovery_runsAllCallbacks() local
|
| /aosp_15_r20/hardware/interfaces/biometrics/common/thread/tests/ |
| H A D | WorkerThreadTest.cpp | 106 auto future2 = promise2.get_future(); in TEST() local
|
| /aosp_15_r20/external/aws-sdk-java-v2/services/s3/src/it/java/software/amazon/awssdk/services/s3/ |
| H A D | ListObjectsV2PaginatorsIntegrationTest.java | 180 CompletableFuture<Void> future2 = publisher.subscribe(response -> { in test_AsyncResponse_OnNonEmptyBucket() local
|
| /aosp_15_r20/packages/modules/Bluetooth/system/gd/os/linux_generic/ |
| D | alarm_unittest.cc | 134 auto future2 = promise2->get_future(); in TEST_P() local
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tokio/tests/ |
| D | sync_notify.rs | 283 let mut future2 = spawn(notify.notified()); in test_enable_consumes_permit() localVariable
|
| /aosp_15_r20/external/aws-sdk-java-v2/services-custom/s3-transfer-manager/src/test/java/software/amazon/awssdk/transfer/s3/internal/ |
| H A D | UploadDirectoryHelperTest.java | 118 CompletableFuture<CompletedFileUpload> future2 = new CompletableFuture<>(); in uploadDirectory_cancel_shouldCancelAllFutures() local
|