Home
last modified time | relevance | path

Searched defs:executeFuture (Results 1 – 25 of 37) sorted by relevance

12

/aosp_15_r20/external/aws-sdk-java-v2/services/kms/target/generated-sources/sdk/software/amazon/awssdk/services/kms/
H A DDefaultKmsAsyncClient.java371 CompletableFuture<CancelKeyDeletionResponse> executeFuture = clientHandler in cancelKeyDeletion() local
649 CompletableFuture<ConnectCustomKeyStoreResponse> executeFuture = clientHandler in connectCustomKeyStore() local
830 CompletableFuture<CreateAliasResponse> executeFuture = clientHandler in createAlias() local
1123 CompletableFuture<CreateCustomKeyStoreResponse> executeFuture = clientHandler in createCustomKeyStore() local
1303 CompletableFuture<CreateGrantResponse> executeFuture = clientHandler in createGrant() local
1703 CompletableFuture<CreateKeyResponse> executeFuture = clientHandler in createKey() local
1946 CompletableFuture<DecryptResponse> executeFuture = clientHandler in decrypt() local
2103 CompletableFuture<DeleteAliasResponse> executeFuture = clientHandler in deleteAlias() local
2293 CompletableFuture<DeleteCustomKeyStoreResponse> executeFuture = clientHandler in deleteCustomKeyStore() local
2429 CompletableFuture<DeleteImportedKeyMaterialResponse> executeFuture = clientHandler in deleteImportedKeyMaterial() local
[all …]
/aosp_15_r20/external/aws-sdk-java-v2/codegen/src/test/resources/software/amazon/awssdk/codegen/poet/client/sra/
H A Dtest-json-async-client-class.java200 CompletableFuture<APostOperationResponse> executeFuture = clientHandler in aPostOperation() local
262 CompletableFuture<APostOperationWithOutputResponse> executeFuture = clientHandler in aPostOperationWithOutput() local
320 CompletableFuture<BearerAuthOperationResponse> executeFuture = clientHandler in bearerAuthOperation() local
404 CompletableFuture<Void> executeFuture = clientHandler.execute( in eventStreamOperation() local
480 … CompletableFuture<EventStreamOperationWithOnlyInputResponse> executeFuture = clientHandler in eventStreamOperationWithOnlyInput() local
561 CompletableFuture<Void> executeFuture = clientHandler in eventStreamOperationWithOnlyOutput() local
630 CompletableFuture<GetOperationWithChecksumResponse> executeFuture = clientHandler in getOperationWithChecksum() local
699 CompletableFuture<GetWithoutRequiredMembersResponse> executeFuture = clientHandler in getWithoutRequiredMembers() local
758 CompletableFuture<OperationWithChecksumRequiredResponse> executeFuture = clientHandler in operationWithChecksumRequired() local
821 CompletableFuture<OperationWithRequestCompressionResponse> executeFuture = clientHandler in operationWithRequestCompression() local
[all …]
H A Dtest-query-async-client-class.java152 CompletableFuture<APostOperationResponse> executeFuture = clientHandler in aPostOperation() local
211 CompletableFuture<APostOperationWithOutputResponse> executeFuture = clientHandler in aPostOperationWithOutput() local
266 CompletableFuture<BearerAuthOperationResponse> executeFuture = clientHandler in bearerAuthOperation() local
321 CompletableFuture<GetOperationWithChecksumResponse> executeFuture = clientHandler in getOperationWithChecksum() local
384 CompletableFuture<OperationWithChecksumRequiredResponse> executeFuture = clientHandler in operationWithChecksumRequired() local
443 CompletableFuture<OperationWithContextParamResponse> executeFuture = clientHandler in operationWithContextParam() local
498 CompletableFuture<OperationWithNoneAuthTypeResponse> executeFuture = clientHandler in operationWithNoneAuthType() local
554 CompletableFuture<OperationWithRequestCompressionResponse> executeFuture = clientHandler in operationWithRequestCompression() local
615 … CompletableFuture<OperationWithStaticContextParamsResponse> executeFuture = clientHandler in operationWithStaticContextParams() local
693 CompletableFuture<ReturnT> executeFuture = clientHandler.execute( in putOperationWithChecksum() local
[all …]
H A Dtest-aws-json-async-client-class.java192 CompletableFuture<APostOperationResponse> executeFuture = clientHandler in aPostOperation() local
255 CompletableFuture<APostOperationWithOutputResponse> executeFuture = clientHandler in aPostOperationWithOutput() local
335 CompletableFuture<Void> executeFuture = clientHandler.execute( in eventStreamOperation() local
412 … CompletableFuture<EventStreamOperationWithOnlyInputResponse> executeFuture = clientHandler in eventStreamOperationWithOnlyInput() local
490 CompletableFuture<Void> executeFuture = clientHandler.execute( in eventStreamOperationWithOnlyOutput() local
561 CompletableFuture<GetWithoutRequiredMembersResponse> executeFuture = clientHandler in getWithoutRequiredMembers() local
620 CompletableFuture<OperationWithChecksumRequiredResponse> executeFuture = clientHandler in operationWithChecksumRequired() local
682 CompletableFuture<OperationWithNoneAuthTypeResponse> executeFuture = clientHandler in operationWithNoneAuthType() local
741 CompletableFuture<OperationWithRequestCompressionResponse> executeFuture = clientHandler in operationWithRequestCompression() local
805 CompletableFuture<PaginatedOperationWithResultKeyResponse> executeFuture = clientHandler in paginatedOperationWithResultKey() local
[all …]
H A Dtest-xml-async-client-class.java156 CompletableFuture<APostOperationResponse> executeFuture = clientHandler in aPostOperation() local
215 CompletableFuture<APostOperationWithOutputResponse> executeFuture = clientHandler in aPostOperationWithOutput() local
270 CompletableFuture<BearerAuthOperationResponse> executeFuture = clientHandler in bearerAuthOperation() local
342 CompletableFuture<Void> executeFuture = clientHandler.execute( in eventStreamOperation() local
405 CompletableFuture<GetOperationWithChecksumResponse> executeFuture = clientHandler in getOperationWithChecksum() local
467 CompletableFuture<OperationWithChecksumRequiredResponse> executeFuture = clientHandler in operationWithChecksumRequired() local
525 CompletableFuture<OperationWithNoneAuthTypeResponse> executeFuture = clientHandler in operationWithNoneAuthType() local
581 CompletableFuture<OperationWithRequestCompressionResponse> executeFuture = clientHandler in operationWithRequestCompression() local
664 CompletableFuture<ReturnT> executeFuture = clientHandler.execute( in putOperationWithChecksum() local
745 CompletableFuture<StreamingInputOperationResponse> executeFuture = clientHandler in streamingInputOperation() local
[all …]
/aosp_15_r20/external/aws-sdk-java-v2/codegen/src/test/resources/software/amazon/awssdk/codegen/poet/client/
H A Dtest-json-async-client-class.java208 CompletableFuture<APostOperationResponse> executeFuture = clientHandler in aPostOperation() local
270 CompletableFuture<APostOperationWithOutputResponse> executeFuture = clientHandler in aPostOperationWithOutput() local
329 CompletableFuture<BearerAuthOperationResponse> executeFuture = clientHandler in bearerAuthOperation() local
414 CompletableFuture<Void> executeFuture = clientHandler.execute( in eventStreamOperation() local
492 … CompletableFuture<EventStreamOperationWithOnlyInputResponse> executeFuture = clientHandler in eventStreamOperationWithOnlyInput() local
573 CompletableFuture<Void> executeFuture = clientHandler in eventStreamOperationWithOnlyOutput() local
642 CompletableFuture<GetOperationWithChecksumResponse> executeFuture = clientHandler in getOperationWithChecksum() local
711 CompletableFuture<GetWithoutRequiredMembersResponse> executeFuture = clientHandler in getWithoutRequiredMembers() local
770 CompletableFuture<OperationWithChecksumRequiredResponse> executeFuture = clientHandler in operationWithChecksumRequired() local
833 CompletableFuture<OperationWithRequestCompressionResponse> executeFuture = clientHandler in operationWithRequestCompression() local
[all …]
H A Dtest-aws-json-async-client-class.java199 CompletableFuture<APostOperationResponse> executeFuture = clientHandler in aPostOperation() local
262 CompletableFuture<APostOperationWithOutputResponse> executeFuture = clientHandler in aPostOperationWithOutput() local
343 CompletableFuture<Void> executeFuture = clientHandler.execute( in eventStreamOperation() local
422 … CompletableFuture<EventStreamOperationWithOnlyInputResponse> executeFuture = clientHandler in eventStreamOperationWithOnlyInput() local
500 CompletableFuture<Void> executeFuture = clientHandler.execute( in eventStreamOperationWithOnlyOutput() local
571 CompletableFuture<GetWithoutRequiredMembersResponse> executeFuture = clientHandler in getWithoutRequiredMembers() local
630 CompletableFuture<OperationWithChecksumRequiredResponse> executeFuture = clientHandler in operationWithChecksumRequired() local
692 CompletableFuture<OperationWithNoneAuthTypeResponse> executeFuture = clientHandler in operationWithNoneAuthType() local
752 CompletableFuture<OperationWithRequestCompressionResponse> executeFuture = clientHandler in operationWithRequestCompression() local
816 CompletableFuture<PaginatedOperationWithResultKeyResponse> executeFuture = clientHandler in paginatedOperationWithResultKey() local
[all …]
H A Dtest-query-async-client-class.java158 CompletableFuture<APostOperationResponse> executeFuture = clientHandler in aPostOperation() local
217 CompletableFuture<APostOperationWithOutputResponse> executeFuture = clientHandler in aPostOperationWithOutput() local
273 CompletableFuture<BearerAuthOperationResponse> executeFuture = clientHandler in bearerAuthOperation() local
328 CompletableFuture<GetOperationWithChecksumResponse> executeFuture = clientHandler in getOperationWithChecksum() local
391 CompletableFuture<OperationWithChecksumRequiredResponse> executeFuture = clientHandler in operationWithChecksumRequired() local
450 CompletableFuture<OperationWithContextParamResponse> executeFuture = clientHandler in operationWithContextParam() local
505 CompletableFuture<OperationWithNoneAuthTypeResponse> executeFuture = clientHandler in operationWithNoneAuthType() local
562 CompletableFuture<OperationWithRequestCompressionResponse> executeFuture = clientHandler in operationWithRequestCompression() local
623 … CompletableFuture<OperationWithStaticContextParamsResponse> executeFuture = clientHandler in operationWithStaticContextParams() local
704 CompletableFuture<ReturnT> executeFuture = clientHandler.execute( in putOperationWithChecksum() local
[all …]
H A Dtest-xml-async-client-class.java162 CompletableFuture<APostOperationResponse> executeFuture = clientHandler in aPostOperation() local
221 CompletableFuture<APostOperationWithOutputResponse> executeFuture = clientHandler in aPostOperationWithOutput() local
277 CompletableFuture<BearerAuthOperationResponse> executeFuture = clientHandler in bearerAuthOperation() local
349 CompletableFuture<Void> executeFuture = clientHandler.execute( in eventStreamOperation() local
412 CompletableFuture<GetOperationWithChecksumResponse> executeFuture = clientHandler in getOperationWithChecksum() local
474 CompletableFuture<OperationWithChecksumRequiredResponse> executeFuture = clientHandler in operationWithChecksumRequired() local
532 CompletableFuture<OperationWithNoneAuthTypeResponse> executeFuture = clientHandler in operationWithNoneAuthType() local
589 CompletableFuture<OperationWithRequestCompressionResponse> executeFuture = clientHandler in operationWithRequestCompression() local
675 CompletableFuture<ReturnT> executeFuture = clientHandler.execute( in putOperationWithChecksum() local
759 CompletableFuture<StreamingInputOperationResponse> executeFuture = clientHandler in streamingInputOperation() local
[all …]
H A Dtest-endpoint-discovery-async.java122 CompletableFuture<DescribeEndpointsResponse> executeFuture = clientHandler in describeEndpoints() local
203 … CompletableFuture<TestDiscoveryIdentifiersRequiredResponse> executeFuture = endpointFuture in testDiscoveryIdentifiersRequired() local
275 CompletableFuture<TestDiscoveryOptionalResponse> executeFuture = endpointFuture in testDiscoveryOptional() local
355 CompletableFuture<TestDiscoveryRequiredResponse> executeFuture = endpointFuture in testDiscoveryRequired() local
/aosp_15_r20/external/aws-sdk-java-v2/http-clients/aws-crt-client/src/test/java/software/amazon/awssdk/http/crt/internal/
H A DCrtAsyncRequestExecutorTest.java83 CompletableFuture<Void> executeFuture = requestExecutor.execute(context); in acquireConnectionThrowException_shouldInvokeOnError() local
106 CompletableFuture<Void> executeFuture = requestExecutor.execute(context); in executeAsyncRequest_CrtRuntimeException_shouldInvokeOnError() local
129 CompletableFuture<Void> executeFuture = requestExecutor.execute(context); in cancelRequest_shouldInvokeOnError() local
148 CompletableFuture<Void> executeFuture = requestExecutor.execute(context); in execute_AcquireConnectionFailure_shouldAlwaysWrapIOException() local
164 CompletableFuture<Void> executeFuture = requestExecutor.execute(context); in executeRequest_failedOfIllegalStateException_shouldWrapIOException() local
186 CompletableFuture<Void> executeFuture = requestExecutor.execute(context); in executeRequest_failedOfRetryableHttpException_shouldWrapIOException() local
208 CompletableFuture<Void> executeFuture = requestExecutor.execute(context); in executeRequest_failedOfNonRetryableHttpException_shouldNotWrapIOException() local
H A DCrtRequestExecutorTest.java81 CompletableFuture<SdkHttpFullResponse> executeFuture = requestExecutor.execute(context); in acquireConnectionThrowException_shouldInvokeOnError() local
98 CompletableFuture<SdkHttpFullResponse> executeFuture = requestExecutor.execute(context); in makeRequestFailed_retryableException_shouldWrapWithIOException() local
110 CompletableFuture<SdkHttpFullResponse> executeFuture = requestExecutor.execute(context); in execute_AcquireConnectionFailure_shouldAlwaysWrapIOException() local
126 CompletableFuture<SdkHttpFullResponse> executeFuture = requestExecutor.execute(context); in executeRequest_failedOfNonRetryableHttpException_shouldNotWrapIOException() local
/aosp_15_r20/external/aws-sdk-java-v2/http-clients/netty-nio-client/src/main/java/software/amazon/awssdk/http/nio/netty/internal/
H A DResponseHandler.java273 private static CompletableFuture<Void> executeFuture(ChannelHandlerContext ctx) { in executeFuture() method in ResponseHandler
281 private final CompletableFuture<Void> executeFuture; field in ResponseHandler.PublisherAdapter
285 RequestContext requestContext, CompletableFuture<Void> executeFuture) { in PublisherAdapter()
422 private final CompletableFuture<Void> executeFuture; field in ResponseHandler.FullResponseContentPublisher
427 CompletableFuture<Void> executeFuture) { in FullResponseContentPublisher()
H A DUnusedChannelExceptionHandler.java56 …Optional<CompletableFuture<Void>> executeFuture = getAttribute(ctx.channel(), ChannelAttributeKey.… in exceptionCaught() local
/aosp_15_r20/external/aws-sdk-java-v2/http-clients/netty-nio-client/src/test/java/software/amazon/awssdk/http/nio/netty/internal/
H A DNettyRequestExecutorTest.java97 CompletableFuture<Void> executeFuture = nettyRequestExecutor.execute(); in cancelExecuteFuture_channelNotAcquired_failsAcquirePromise() local
159 CompletableFuture<Void> executeFuture = nettyRequestExecutor.execute(); in cancelExecuteFuture_channelAcquired_submitsRunnable() local
H A DFullResponseContentPublisherTckTest.java39 private CompletableFuture<Void> executeFuture; field in FullResponseContentPublisherTckTest
/aosp_15_r20/external/aws-sdk-java-v2/core/sdk-core/src/test/java/software/amazon/awssdk/core/internal/http/pipeline/stages/
H A DMakeAsyncHttpRequestStageTest.java185 CompletableFuture executeFuture = stage.execute(requestFuture, requestContext()); in execute_handlerFutureCompletedNormally_futureCompletionExecutorRejectsWhenCompleteAsync_futureCompletedSynchronously() local
220 CompletableFuture executeFuture = stage.execute(requestFuture, requestContext()); in execute_handlerFutureCompletedExceptionally_doesNotAttemptSynchronousComplete() local
/aosp_15_r20/external/aws-sdk-java-v2/services/s3/src/main/java/software/amazon/awssdk/services/s3/internal/crt/
H A DS3CrtAsyncHttpClient.java132 CompletableFuture<Void> executeFuture = new CompletableFuture<>(); in execute() local
218 private static void closeResourceCallback(CompletableFuture<Void> executeFuture, in closeResourceCallback()
/aosp_15_r20/external/aws-sdk-java-v2/core/sdk-core/src/main/java/software/amazon/awssdk/core/internal/http/pipeline/stages/
H A DAsyncExecutionFailureExceptionReportingStage.java42 CompletableFuture<OutputT> executeFuture = wrappedExecute.handle((o, t) -> { in execute() local
H A DAsyncApiCallMetricCollectionStage.java49 CompletableFuture<OutputT> executeFuture = wrapped.execute(input, context); in execute() local
H A DAsyncApiCallTimeoutTrackingStage.java64 CompletableFuture<OutputT> executeFuture = requestPipeline.execute(input, context); in execute() local
/aosp_15_r20/external/aws-sdk-java-v2/test/codegen-generated-classes-test/src/test/java/software/amazon/awssdk/services/protocolquery/
H A DAsyncOperationCancelTest.java50 private CompletableFuture executeFuture; field in AsyncOperationCancelTest
/aosp_15_r20/external/aws-sdk-java-v2/test/codegen-generated-classes-test/src/test/java/software/amazon/awssdk/services/protocolrestjson/
H A DAsyncOperationCancelTest.java55 private CompletableFuture<Void> executeFuture; field in AsyncOperationCancelTest
/aosp_15_r20/external/aws-sdk-java-v2/test/codegen-generated-classes-test/src/test/java/software/amazon/awssdk/services/protocolrestxml/
H A DAsyncOperationCancelTest.java54 private CompletableFuture executeFuture; field in AsyncOperationCancelTest
/aosp_15_r20/external/aws-sdk-java-v2/test/ruleset-testing-core/src/main/java/software/amazon/awssdk/core/rules/testing/
H A DBaseRuleSetClientTest.java107 CompletableFuture<?> executeFuture = r.get(); in runAndVerify() local

12