| /aosp_15_r20/external/aws-sdk-java-v2/test/codegen-generated-classes-test/src/test/java/software/amazon/awssdk/services/ |
| H A D | BlockingAsyncRequestResponseBodyTest.java | 186 CompletableFuture<StreamingInputOperationResponse> responseFuture = in blockingWithExecutor_propagatesReadFailures() local
202 CompletableFuture<?> responseFuture = in blockingWithExecutor_propagates400Failures() local
218 CompletableFuture<?> responseFuture = in blockingWithExecutor_propagates500Failures() local
234 CompletableFuture<?> responseFuture = in blockingInputStreamWithoutExecutor_sendsRightValues() local
251 CompletableFuture<?> responseFuture = in blockingInputStreamWithoutExecutor_canUnderUpload() local
268 CompletableFuture<?> responseFuture = in blockingInputStreamWithoutExecutor_canUnderUploadOneByteAtATime() local
285 CompletableFuture<StreamingInputOperationResponse> responseFuture = in blockingInputStreamWithoutExecutor_propagatesReadFailures() local
297 CompletableFuture<?> responseFuture = in blockingInputStreamWithoutExecutor_propagates400Failures() local
308 CompletableFuture<StreamingInputOperationResponse> responseFuture = in blockingInputStreamWithoutExecutor_propagates500Failures() local
320 CompletableFuture<ResponseInputStream<StreamingOutputOperationResponse>> responseFuture = in blockingResponseTransformer_readsRightValue() local
[all …]
|
| /aosp_15_r20/external/downloader/src/test/java/com/google/android/downloader/ |
| H A D | MockWebServerUrlEngineTestHelper.java | 86 ListenableFuture<UrlResponse> responseFuture = request.send(); in executeRequest_normalResponse_succeeds() local
130 ListenableFuture<UrlResponse> responseFuture = request.send(); in executeRequest_responseThrottled_succeeds() local
178 ListenableFuture<UrlResponse> responseFuture = request.send(); in executeRequest_largeResponse_succeeds() local
216 ListenableFuture<UrlResponse> responseFuture = request.send(); in executeRequest_closeBeforeWrite_failsAborted() local
234 ListenableFuture<UrlResponse> responseFuture = request.send(); in executeRequest_serverError_failsInternalError() local
255 ListenableFuture<UrlResponse> responseFuture = request.send(); in executeRequest_networkError_failsInternalError() local
271 ListenableFuture<UrlResponse> responseFuture = request.send(); in executeRequest_writeError_failsInternalError() local
298 ListenableFuture<UrlResponse> responseFuture = request.send(); in executeRequest_requestCanceled_requestNeverSent() local
312 ListenableFuture<UrlResponse> responseFuture = request.send(); in executeRequest_invalidUrl_failsInvalidArgument() local
|
| /aosp_15_r20/external/downloader/src/main/java/com/google/android/downloader/ |
| H A D | CronetUrlEngine.java | 69 SettableFuture<UrlResponse> responseFuture = SettableFuture.create(); in createRequest() local
84 private final ListenableFuture<UrlResponse> responseFuture; field in CronetUrlEngine.CronetUrlRequest
109 private final ListenableFuture<UrlResponse> responseFuture; field in CronetUrlEngine.CronetUrlRequestBuilder
113 ListenableFuture<UrlResponse> responseFuture) { in CronetUrlRequestBuilder()
181 private final SettableFuture<UrlResponse> responseFuture; field in CronetUrlEngine.CronetCallback
188 CronetCallback(SettableFuture<UrlResponse> responseFuture) { in CronetCallback()
|
| /aosp_15_r20/external/aws-sdk-java-v2/test/codegen-generated-classes-test/src/test/java/software/amazon/awssdk/services/protocolrestjson/ |
| H A D | AsyncOperationCancelTest.java | 72 CompletableFuture<AllTypesResponse> responseFuture = client.allTypes(r -> {}); in testNonStreamingOperation() local
80 …CompletableFuture<StreamingInputOperationResponse> responseFuture = client.streamingInputOperation… in testStreamingOperation() local
88 …CompletableFuture<ResponseBytes<StreamingOutputOperationResponse>> responseFuture = client.streami… in testStreamingOutputOperation() local
97 CompletableFuture<Void> responseFuture = in testEventStreamingOperation() local
|
| /aosp_15_r20/external/aws-sdk-java-v2/test/codegen-generated-classes-test/src/test/java/software/amazon/awssdk/services/protocolrestxml/ |
| H A D | AsyncOperationCancelTest.java | 71 CompletableFuture<AllTypesResponse> responseFuture = client.allTypes(r -> { in testNonStreamingOperation() local
80 …CompletableFuture<StreamingInputOperationResponse> responseFuture = client.streamingInputOperation… in testStreamingInputOperation() local
88 …CompletableFuture<ResponseBytes<StreamingOutputOperationResponse>> responseFuture = client.streami… in testStreamingOutputOperation() local
97 CompletableFuture<Void> responseFuture = client.eventStreamOperation(r -> { in testEventStreamingOperation() local
|
| /aosp_15_r20/external/aws-sdk-java-v2/test/codegen-generated-classes-test/src/test/java/software/amazon/awssdk/services/protocolquery/ |
| H A D | AsyncOperationCancelTest.java | 67 CompletableFuture<AllTypesResponse> responseFuture = client.allTypes(r -> { in testNonStreamingOperation() local
76 …CompletableFuture<StreamingInputOperationResponse> responseFuture = client.streamingInputOperation… in testStreamingInputOperation() local
84 …CompletableFuture<ResponseBytes<StreamingOutputOperationResponse>> responseFuture = client.streami… in testStreamingOutputOperation() local
|
| /aosp_15_r20/external/aws-sdk-java-v2/core/sdk-core/src/test/java/software/amazon/awssdk/core/internal/async/ |
| H A D | PublisherAsyncResponseTransformerTest.java | 51 CompletableFuture<ResponsePublisher<SdkResponse>> responseFuture = transformer.prepare(); in successfulResponseAndStream_returnsResponsePublisher() local
64 CompletableFuture<ResponsePublisher<SdkResponse>> responseFuture = transformer.prepare(); in failedResponse_completesExceptionally() local
75 CompletableFuture<ResponsePublisher<SdkResponse>> responseFuture = transformer.prepare(); in failedStream_completesExceptionally() 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 | 81 …CompletableFuture<WaiterResponse<AllTypesResponse>> responseFuture = asyncWaiter.waitUntilAllTypes… in allTypeOperation_withAsyncWaiter_shouldReturnResponse() local
95 …CompletableFuture<WaiterResponse<AllTypesResponse>> responseFuture = asyncWaiter.waitUntilAllTypes… in allTypeOperationFailed_withAsyncWaiter_shouldReturnException() local
117 …CompletableFuture<WaiterResponse<AllTypesResponse>> responseFuture = asyncWaiter.waitUntilAllTypes… in allTypeOperationRetry_withAsyncWaiter_shouldReturnResponseAfterException() local
|
| /aosp_15_r20/packages/modules/AdServices/adservices/tests/cts/ui/enrollment/ctsroot/src/com/android/adservices/tests/enrollmentctsroot/ |
| D | AdServicesEnrollmentCtsRootTest.java | 66 ListenableFuture<Integer> responseFuture = in testRequestAdServicesModuleOverrides() local
96 ListenableFuture<Integer> responseFuture = in testRequestAdServicesModuleUserChoices() local
|
| /aosp_15_r20/external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/ |
| H A D | ClientCalls.java | 158 ListenableFuture<RespT> responseFuture = futureUnaryCall(call, req); in blockingUnaryCall() local
230 GrpcFuture<RespT> responseFuture = new GrpcFuture<>(call); in futureUnaryCall() local
514 private final GrpcFuture<RespT> responseFuture; field in ClientCalls.UnaryStreamToFuture
519 UnaryStreamToFuture(GrpcFuture<RespT> responseFuture) { in UnaryStreamToFuture()
|
| /aosp_15_r20/system/chre/java/test/utils/src/com/google/android/utils/chre/ |
| H A D | ChreApiTestUtil.java | 131 Future<List<List<ResponseType>>> responseFuture = in callConcurrentServerStreamingRpcMethodSync() local
635 ServerStreamingFuture responseFuture = methodClient.invokeServerStreamingFuture( in callConcurrentServerStreamingRpcMethodAsync() local
650 Future<List<List<ResponseType>>> responseFuture = mExecutor.submit(() -> { in callConcurrentServerStreamingRpcMethodAsync() local
|
| /aosp_15_r20/external/aws-sdk-java-v2/core/sdk-core/src/test/java/software/amazon/awssdk/core/client/handler/ |
| H A D | AsyncClientHandlerTest.java | 97 …CompletableFuture<SdkResponse> responseFuture = asyncClientHandler.execute(clientExecutionParams()… in successfulExecutionCallsResponseHandler() local
122 …CompletableFuture<SdkResponse> responseFuture = asyncClientHandler.execute(clientExecutionParams()… in failedExecutionCallsErrorResponseHandler() local
|
| /aosp_15_r20/external/aws-sdk-java-v2/core/imds/src/test/java/software/amazon/awssdk/imds/internal/ |
| H A D | Ec2MetadataAsyncClientTest.java | 101 CompletableFuture<Ec2MetadataResponse> responseFuture = client.get(AMI_ID_RESOURCE); in get_cancelResponseFuture_shouldCancelHttpRequest() local
120 CompletableFuture<Ec2MetadataResponse> responseFuture = buildClient.get(AMI_ID_RESOURCE); in builder_httpClientWithDefaultBuilder_shouldBuildProperly() local
|
| /aosp_15_r20/external/aws-sdk-java-v2/core/sdk-core/src/main/java/software/amazon/awssdk/core/internal/http/pipeline/stages/ |
| H A D | MakeAsyncHttpRequestStage.java | 128 CompletableFuture<Response<OutputT>> responseFuture = new CompletableFuture<>(); in executeHttpRequest() local
251 …private void completeResponseFuture(CompletableFuture<Response<OutputT>> responseFuture, Response<… in completeResponseFuture()
|
| /aosp_15_r20/external/pytorch/torch/csrc/distributed/rpc/ |
| H A D | request_callback_no_python.cpp | 322 auto responseFuture = wrappedRpcResponseFuture->then( in processForwardAutogradReq() local
450 auto responseFuture = wrappedRpcResponseFuture->then( in processRunWithProfilingReq() local
|
| /aosp_15_r20/packages/modules/AdServices/adservices/tests/cts/ui/enrollment/shelle2e/src/com/android/adservices/tests/enrollment/ |
| D | AdServicesEnrollmentTest.java | 72 ListenableFuture<Integer> responseFuture = in testEnableAdServices() local
|
| /aosp_15_r20/packages/modules/AdServices/adservices/tests/cts/ui/u18ux/detentionchannel/src/com/android/adservices/tests/ui/u18ux/detentionchannel/ |
| D | U18UxDetentionChannelTest.java | 85 SettableFuture<Boolean> responseFuture = SettableFuture.create(); in setUp() local
|
| /aosp_15_r20/packages/modules/AdServices/adservices/apk/tests/engonly/gaux/graduationchannel/src/com/android/adservices/tests/ui/gaux/graduationchannel/ |
| D | ExtGaUxGraduationChannelRowTest.java | 123 SettableFuture<Boolean> responseFuture = SettableFuture.create(); in setUp() local
|
| /aosp_15_r20/packages/modules/AdServices/adservices/apk/tests/engonly/gaux/alreadyenrolledchannel/src/com/android/adservices/tests/ui/gaux/alreadyenrolledchannel/ |
| D | ExtGaUxAlreadyEnrolledChannelEuTest.java | 93 SettableFuture<Boolean> responseFuture = SettableFuture.create(); in setUp() local
|
| D | ExtGaUxAlreadyEnrolledChannelRowTest.java | 93 SettableFuture<Boolean> responseFuture = SettableFuture.create(); in setUp() local
|
| /aosp_15_r20/external/aws-sdk-java-v2/services/dynamodb/src/it/java/software/amazon/awssdk/services/dynamodb/ |
| H A D | WaitersIntegrationTest.java | 97 …CompletableFuture<WaiterResponse<DescribeTableResponse>> responseFuture = asyncWaiter.waitUntilTab… in checkTableExist_withAsyncWaiter() local
|
| /aosp_15_r20/packages/modules/AdServices/adservices/tests/cts/ui/gaux/graduationchannel/src/com/android/adservices/tests/ui/gaux/graduationchannel/ |
| D | GaUxGraduationChannelTest.java | 91 SettableFuture<Boolean> responseFuture = SettableFuture.create(); in setUp() local
|
| /aosp_15_r20/external/aws-sdk-java-v2/services/dynamodb/src/test/java/software/amazon/awssdk/services/dynamodb/ |
| H A D | WaitersUserAgentTest.java | 95 …CompletableFuture<WaiterResponse<DescribeTableResponse>> responseFuture = waiter.waitUntilTableExi… in asyncWaiters_shouldHaveWaitersUserAgent() local
|
| /aosp_15_r20/packages/modules/AdServices/adservices/tests/cts/ui/gaux/alreadyenrolledchannel/src/com/android/adservices/tests/ui/gaux/alreadyenrolledchannel/ |
| D | GaUxAlreadyEnrolledChannelTest.java | 92 SettableFuture<Boolean> responseFuture = SettableFuture.create(); in setUp() local
|
| /aosp_15_r20/packages/modules/AdServices/adservices/service-core/java/com/android/adservices/service/shell/adservicesapi/ |
| D | EnableAdServicesCommand.java | 86 ListenableFuture<Boolean> responseFuture = in run() local
|