Home
last modified time | relevance | path

Searched defs:responseFuture (Results 1 – 25 of 29) sorted by relevance

12

/external/aws-sdk-java-v2/test/codegen-generated-classes-test/src/test/java/software/amazon/awssdk/services/
DBlockingAsyncRequestResponseBodyTest.java186 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 …]
/external/aws-sdk-java-v2/test/codegen-generated-classes-test/src/test/java/software/amazon/awssdk/services/protocolrestxml/
DAsyncOperationCancelTest.java71 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
/external/aws-sdk-java-v2/test/codegen-generated-classes-test/src/test/java/software/amazon/awssdk/services/protocolrestjson/
DAsyncOperationCancelTest.java72 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
/external/downloader/src/test/java/com/google/android/downloader/
DMockWebServerUrlEngineTestHelper.java86 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
DDataUrlEngineTest.java81 ListenableFuture<? extends UrlResponse> responseFuture = request.send(); in executeRequest_invalidDataUrl() local
DCronetUrlEngineTest.java116 ListenableFuture<? extends UrlResponse> responseFuture = request.send(); in executeRequest_fileUrl_requestFails() local
DPlatformUrlEngineTest.java119 ListenableFuture<? extends UrlResponse> responseFuture = request.send(); in executeRequest_fileUrl() local
/external/aws-sdk-java-v2/test/codegen-generated-classes-test/src/test/java/software/amazon/awssdk/services/protocolquery/
DAsyncOperationCancelTest.java67 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
/external/aws-sdk-java-v2/core/sdk-core/src/test/java/software/amazon/awssdk/core/internal/async/
DPublisherAsyncResponseTransformerTest.java51 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
/external/downloader/src/main/java/com/google/android/downloader/
DCronetUrlEngine.java69 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()
DOkHttp2UrlEngine.java125 SettableFuture<UrlResponse> responseFuture = SettableFuture.create(); in send() local
DOkHttp3UrlEngine.java125 SettableFuture<UrlResponse> responseFuture = SettableFuture.create(); in send() local
/external/aws-sdk-java-v2/test/codegen-generated-classes-test/src/test/java/software/amazon/awssdk/services/waiters/
DWaitersAsyncFunctionalTest.java81 …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
/external/aws-sdk-java-v2/core/sdk-core/src/test/java/software/amazon/awssdk/core/client/handler/
DAsyncClientHandlerTest.java97 …CompletableFuture<SdkResponse> responseFuture = asyncClientHandler.execute(clientExecutionParams()… in successfulExecutionCallsResponseHandler() local
122 …CompletableFuture<SdkResponse> responseFuture = asyncClientHandler.execute(clientExecutionParams()… in failedExecutionCallsErrorResponseHandler() local
/external/aws-sdk-java-v2/core/imds/src/test/java/software/amazon/awssdk/imds/internal/
DEc2MetadataAsyncClientTest.java101 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
/external/aws-sdk-java-v2/services/dynamodb/src/it/java/software/amazon/awssdk/services/dynamodb/
DWaitersIntegrationTest.java97 …CompletableFuture<WaiterResponse<DescribeTableResponse>> responseFuture = asyncWaiter.waitUntilTab… in checkTableExist_withAsyncWaiter() local
/external/aws-sdk-java-v2/services/dynamodb/src/test/java/software/amazon/awssdk/services/dynamodb/
DWaitersUserAgentTest.java95 …CompletableFuture<WaiterResponse<DescribeTableResponse>> responseFuture = waiter.waitUntilTableExi… in asyncWaiters_shouldHaveWaitersUserAgent() local
/external/aws-sdk-java-v2/test/s3-benchmarks/src/main/java/software/amazon/awssdk/s3benchmarks/
DJavaS3ClientUploadBenchmark.java76 CompletableFuture<PutObjectResponse> responseFuture = in uploadFromMemory() local
/external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/
DClientCalls.java158 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()
/external/aws-sdk-java-v2/core/sdk-core/src/main/java/software/amazon/awssdk/core/internal/http/pipeline/stages/
DMakeAsyncHttpRequestStage.java128 CompletableFuture<Response<OutputT>> responseFuture = new CompletableFuture<>(); in executeHttpRequest() local
251 …private void completeResponseFuture(CompletableFuture<Response<OutputT>> responseFuture, Response<… in completeResponseFuture()
DAsyncRetryableStage.java141 CompletableFuture<Response<OutputT>> responseFuture; in attemptExecute() local
/external/bcc/examples/usdt_sample/usdt_sample_app1/
Dmain.cpp132 auto responseFuture = op.executeAsync(OperationRequest(inputOss.str())); in main() local
/external/aws-sdk-java-v2/services/s3/src/it/java/software/amazon/awssdk/services/
DSelectObjectContentIntegrationTest.java111 …CompletableFuture<Void> responseFuture = executeSqlQueryWithHandler("not a query", handler, client… in selectObjectContent_invalidQuery_unmarshallsErrorResponse() local
/external/aws-sdk-java-v2/test/protocol-tests/src/test/java/software/amazon/awssdk/protocol/tests/
DRestXmlEventStreamProtocolTest.java158 CompletableFuture<Void> responseFuture = client.eventStreamOperation(r -> { in errorResponse_unmarshalledCorrectly() local
/external/aws-sdk-java-v2/http-clients/aws-crt-client/src/main/java/software/amazon/awssdk/http/crt/
DAwsCrtHttpClient.java106 private volatile CompletableFuture<SdkHttpFullResponse> responseFuture; field in AwsCrtHttpClient.CrtHttpRequest

12