| /external/aws-sdk-java-v2/utils/src/test/java/software/amazon/awssdk/utils/ |
| D | CompletableFutureUtilsTest.java | 51 CompletableFutureUtils.forwardExceptionTo(src, dst); in testForwardException()
68 …CompletableFuture<String> returnedFuture = CompletableFutureUtils.forwardResultTo(src, dst, execut… in forwardResultTo_srcCompletesSuccessfully_shouldCompleteDstFuture()
81 CompletableFutureUtils.forwardResultTo(src, dst, executors); in forwardResultTo_srcCompletesExceptionally_shouldCompleteDstFuture()
92 …CompletableFuture<Integer> returnedFuture = CompletableFutureUtils.forwardTransformedResultTo(src,… in forwardTransformedResultTo_srcCompletesSuccessfully_shouldCompleteDstFuture()
105 CompletableFutureUtils.forwardTransformedResultTo(src, dst, String::valueOf); in forwardTransformedResultTo_srcCompletesExceptionally_shouldCompleteDstFuture()
118 CompletableFuture<Void> anyFail = CompletableFutureUtils.anyFail(completableFutures); in anyFail_shouldCompleteWhenAnyFutureFails()
130 CompletableFuture<Void> anyFail = CompletableFutureUtils.anyFail(completableFutures); in anyFail_shouldNotCompleteWhenAllFuturesSucceed()
143 …CompletableFuture<Void> resultFuture = CompletableFutureUtils.allOfExceptionForwarded(completableF… in allOfExceptionForwarded_anyFutureFails_shouldForwardExceptionToOthers()
157 …CompletableFuture<Void> resultFuture = CompletableFutureUtils.allOfExceptionForwarded(completableF… in allOfExceptionForwarded_allFutureSucceed_shouldComplete()
171 assertThatThrownBy(() -> CompletableFutureUtils.joinLikeSync(future)) in joinLikeSync_completesExceptionally_throwsUnderlyingException()
[all …]
|
| /external/aws-sdk-java-v2/services/s3/src/test/java/software/amazon/awssdk/services/s3/internal/crossregion/ |
| D | S3CrossRegionAsyncClientRedirectTest.java | 37 import software.amazon.awssdk.utils.CompletableFutureUtils;
52 ….thenReturn(CompletableFutureUtils.failedFuture(new CompletionException(redirectException(redirect… in stubRedirectSuccessSuccess()
80 ….thenReturn(CompletableFutureUtils.failedFuture(new CompletionException(redirectException(redirect… in stubClientAPICallWithFirstRedirectThenSuccessWithRegionInErrorResponse()
98 ….thenReturn(CompletableFutureUtils.failedFuture(new CompletionException(redirectException(301, CRO… in stubApiWithNoBucketField()
107 ….thenReturn(CompletableFutureUtils.failedFuture(new CompletionException(redirectException(301,CROS… in stubHeadBucketRedirect()
109 ….thenReturn(CompletableFutureUtils.failedFuture(new CompletionException(redirectException(301,CROS… in stubHeadBucketRedirect()
115 ….thenReturn(CompletableFutureUtils.failedFuture(new CompletionException(redirectException(redirect… in stubRedirectWithNoRegionAndThenSuccess()
123 ….thenReturn(CompletableFutureUtils.failedFuture(new CompletionException(redirectException(redirect… in stubRedirectThenError()
125 ….thenReturn(CompletableFutureUtils.failedFuture(new CompletionException(redirectException(400, nul… in stubRedirectThenError()
138 .thenReturn(CompletableFutureUtils.failedFuture( in stubApiWithAuthorizationHeaderWithInternalSoftwareError()
[all …]
|
| /external/aws-sdk-java-v2/services/kms/target/generated-sources/sdk/software/amazon/awssdk/services/kms/ |
| D | DefaultKmsAsyncClient.java | 243 import software.amazon.awssdk.utils.CompletableFutureUtils;
381 executeFuture = CompletableFutureUtils.forwardExceptionTo(whenCompleted, executeFuture); in cancelKeyDeletion()
385 return CompletableFutureUtils.failedFuture(t); in cancelKeyDeletion()
659 executeFuture = CompletableFutureUtils.forwardExceptionTo(whenCompleted, executeFuture); in connectCustomKeyStore()
663 return CompletableFutureUtils.failedFuture(t); in connectCustomKeyStore()
840 executeFuture = CompletableFutureUtils.forwardExceptionTo(whenCompleted, executeFuture); in createAlias()
844 return CompletableFutureUtils.failedFuture(t); in createAlias()
1133 executeFuture = CompletableFutureUtils.forwardExceptionTo(whenCompleted, executeFuture); in createCustomKeyStore()
1137 return CompletableFutureUtils.failedFuture(t); in createCustomKeyStore()
1313 executeFuture = CompletableFutureUtils.forwardExceptionTo(whenCompleted, executeFuture); in createGrant()
[all …]
|
| /external/aws-sdk-java-v2/codegen/src/test/resources/software/amazon/awssdk/codegen/poet/client/sra/ |
| D | test-query-async-client-class.java | 80 import software.amazon.awssdk.utils.CompletableFutureUtils;
163 return CompletableFutureUtils.forwardExceptionTo(whenCompleteFuture, executeFuture); in aPostOperation()
166 return CompletableFutureUtils.failedFuture(t); in aPostOperation()
222 return CompletableFutureUtils.forwardExceptionTo(whenCompleteFuture, executeFuture); in aPostOperationWithOutput()
225 return CompletableFutureUtils.failedFuture(t); in aPostOperationWithOutput()
277 return CompletableFutureUtils.forwardExceptionTo(whenCompleteFuture, executeFuture); in bearerAuthOperation()
280 return CompletableFutureUtils.failedFuture(t); in bearerAuthOperation()
339 return CompletableFutureUtils.forwardExceptionTo(whenCompleteFuture, executeFuture); in getOperationWithChecksum()
342 return CompletableFutureUtils.failedFuture(t); in getOperationWithChecksum()
399 return CompletableFutureUtils.forwardExceptionTo(whenCompleteFuture, executeFuture); in operationWithChecksumRequired()
[all …]
|
| D | test-xml-async-client-class.java | 85 import software.amazon.awssdk.utils.CompletableFutureUtils;
167 CompletableFutureUtils.forwardExceptionTo(whenCompleteFuture, executeFuture); in aPostOperation()
171 return CompletableFutureUtils.failedFuture(t); in aPostOperation()
226 CompletableFutureUtils.forwardExceptionTo(whenCompleteFuture, executeFuture); in aPostOperationWithOutput()
230 return CompletableFutureUtils.failedFuture(t); in aPostOperationWithOutput()
281 CompletableFutureUtils.forwardExceptionTo(whenCompleteFuture, executeFuture); in bearerAuthOperation()
285 return CompletableFutureUtils.failedFuture(t); in bearerAuthOperation()
359 CompletableFutureUtils.forwardExceptionTo(whenCompleteFuture, executeFuture); in eventStreamOperation()
360 … return CompletableFutureUtils.forwardExceptionTo(eventStreamTransformFuture, executeFuture); in eventStreamOperation()
365 return CompletableFutureUtils.failedFuture(t); in eventStreamOperation()
[all …]
|
| D | test-json-async-client-class.java | 117 import software.amazon.awssdk.utils.CompletableFutureUtils;
210 executeFuture = CompletableFutureUtils.forwardExceptionTo(whenCompleted, executeFuture); in aPostOperation()
214 return CompletableFutureUtils.failedFuture(t); in aPostOperation()
272 executeFuture = CompletableFutureUtils.forwardExceptionTo(whenCompleted, executeFuture); in aPostOperationWithOutput()
276 return CompletableFutureUtils.failedFuture(t); in aPostOperationWithOutput()
330 executeFuture = CompletableFutureUtils.forwardExceptionTo(whenCompleted, executeFuture); in bearerAuthOperation()
334 return CompletableFutureUtils.failedFuture(t); in bearerAuthOperation()
422 executeFuture = CompletableFutureUtils.forwardExceptionTo(whenCompleted, executeFuture); in eventStreamOperation()
423 return CompletableFutureUtils.forwardExceptionTo(future, executeFuture); in eventStreamOperation()
428 return CompletableFutureUtils.failedFuture(t); in eventStreamOperation()
[all …]
|
| D | test-aws-json-async-client-class.java | 109 import software.amazon.awssdk.utils.CompletableFutureUtils;
202 executeFuture = CompletableFutureUtils.forwardExceptionTo(whenCompleted, executeFuture); in aPostOperation()
206 return CompletableFutureUtils.failedFuture(t); in aPostOperation()
265 executeFuture = CompletableFutureUtils.forwardExceptionTo(whenCompleted, executeFuture); in aPostOperationWithOutput()
269 return CompletableFutureUtils.failedFuture(t); in aPostOperationWithOutput()
354 executeFuture = CompletableFutureUtils.forwardExceptionTo(whenCompleted, executeFuture); in eventStreamOperation()
355 return CompletableFutureUtils.forwardExceptionTo(future, executeFuture); in eventStreamOperation()
360 return CompletableFutureUtils.failedFuture(t); in eventStreamOperation()
423 executeFuture = CompletableFutureUtils.forwardExceptionTo(whenCompleted, executeFuture); in eventStreamOperationWithOnlyInput()
427 return CompletableFutureUtils.failedFuture(t); in eventStreamOperationWithOnlyInput()
[all …]
|
| /external/aws-sdk-java-v2/services-custom/s3-transfer-manager/src/main/java/software/amazon/awssdk/transfer/s3/internal/ |
| D | GenericS3TransferManager.java | 73 import software.amazon.awssdk.utils.CompletableFutureUtils;
136 CompletableFutureUtils.forwardExceptionTo(returnFuture, crtFuture); in upload()
138 CompletableFutureUtils.forwardTransformedResultTo(crtFuture, returnFuture, in upload()
176 CompletableFutureUtils.forwardExceptionTo(returnFuture, putObjectFuture); in uploadFile()
178 CompletableFutureUtils.forwardTransformedResultTo(putObjectFuture, returnFuture, in uploadFile()
198 return new DefaultDirectoryUpload(CompletableFutureUtils.failedFuture(throwable)); in uploadDirectory()
223 CompletableFutureUtils.forwardExceptionTo(returnFuture, crtFuture); in download()
225 CompletableFutureUtils.forwardTransformedResultTo(crtFuture, returnFuture, in download()
267 CompletableFutureUtils.forwardExceptionTo(returnFuture, crtFuture); in doDownloadFile()
269 CompletableFutureUtils.forwardTransformedResultTo(crtFuture, returnFuture, in doDownloadFile()
[all …]
|
| /external/aws-sdk-java-v2/codegen/src/test/resources/software/amazon/awssdk/codegen/poet/client/ |
| D | test-query-async-client-class.java | 86 import software.amazon.awssdk.utils.CompletableFutureUtils;
169 return CompletableFutureUtils.forwardExceptionTo(whenCompleteFuture, executeFuture); in aPostOperation()
172 return CompletableFutureUtils.failedFuture(t); in aPostOperation()
228 return CompletableFutureUtils.forwardExceptionTo(whenCompleteFuture, executeFuture); in aPostOperationWithOutput()
231 return CompletableFutureUtils.failedFuture(t); in aPostOperationWithOutput()
284 return CompletableFutureUtils.forwardExceptionTo(whenCompleteFuture, executeFuture); in bearerAuthOperation()
287 return CompletableFutureUtils.failedFuture(t); in bearerAuthOperation()
346 return CompletableFutureUtils.forwardExceptionTo(whenCompleteFuture, executeFuture); in getOperationWithChecksum()
349 return CompletableFutureUtils.failedFuture(t); in getOperationWithChecksum()
406 return CompletableFutureUtils.forwardExceptionTo(whenCompleteFuture, executeFuture); in operationWithChecksumRequired()
[all …]
|
| D | test-xml-async-client-class.java | 91 import software.amazon.awssdk.utils.CompletableFutureUtils;
173 CompletableFutureUtils.forwardExceptionTo(whenCompleteFuture, executeFuture); in aPostOperation()
177 return CompletableFutureUtils.failedFuture(t); in aPostOperation()
232 CompletableFutureUtils.forwardExceptionTo(whenCompleteFuture, executeFuture); in aPostOperationWithOutput()
236 return CompletableFutureUtils.failedFuture(t); in aPostOperationWithOutput()
288 CompletableFutureUtils.forwardExceptionTo(whenCompleteFuture, executeFuture); in bearerAuthOperation()
292 return CompletableFutureUtils.failedFuture(t); in bearerAuthOperation()
366 CompletableFutureUtils.forwardExceptionTo(whenCompleteFuture, executeFuture); in eventStreamOperation()
367 … return CompletableFutureUtils.forwardExceptionTo(eventStreamTransformFuture, executeFuture); in eventStreamOperation()
372 return CompletableFutureUtils.failedFuture(t); in eventStreamOperation()
[all …]
|
| D | test-aws-json-async-client-class.java | 116 import software.amazon.awssdk.utils.CompletableFutureUtils;
209 executeFuture = CompletableFutureUtils.forwardExceptionTo(whenCompleted, executeFuture); in aPostOperation()
213 return CompletableFutureUtils.failedFuture(t); in aPostOperation()
272 executeFuture = CompletableFutureUtils.forwardExceptionTo(whenCompleted, executeFuture); in aPostOperationWithOutput()
276 return CompletableFutureUtils.failedFuture(t); in aPostOperationWithOutput()
362 executeFuture = CompletableFutureUtils.forwardExceptionTo(whenCompleted, executeFuture); in eventStreamOperation()
363 return CompletableFutureUtils.forwardExceptionTo(future, executeFuture); in eventStreamOperation()
368 return CompletableFutureUtils.failedFuture(t); in eventStreamOperation()
433 executeFuture = CompletableFutureUtils.forwardExceptionTo(whenCompleted, executeFuture); in eventStreamOperationWithOnlyInput()
437 return CompletableFutureUtils.failedFuture(t); in eventStreamOperationWithOnlyInput()
[all …]
|
| D | test-json-async-client-class.java | 125 import software.amazon.awssdk.utils.CompletableFutureUtils;
218 executeFuture = CompletableFutureUtils.forwardExceptionTo(whenCompleted, executeFuture); in aPostOperation()
222 return CompletableFutureUtils.failedFuture(t); in aPostOperation()
280 executeFuture = CompletableFutureUtils.forwardExceptionTo(whenCompleted, executeFuture); in aPostOperationWithOutput()
284 return CompletableFutureUtils.failedFuture(t); in aPostOperationWithOutput()
339 executeFuture = CompletableFutureUtils.forwardExceptionTo(whenCompleted, executeFuture); in bearerAuthOperation()
343 return CompletableFutureUtils.failedFuture(t); in bearerAuthOperation()
432 executeFuture = CompletableFutureUtils.forwardExceptionTo(whenCompleted, executeFuture); in eventStreamOperation()
433 return CompletableFutureUtils.forwardExceptionTo(future, executeFuture); in eventStreamOperation()
438 return CompletableFutureUtils.failedFuture(t); in eventStreamOperation()
[all …]
|
| D | test-endpoint-discovery-async.java | 52 import software.amazon.awssdk.utils.CompletableFutureUtils;
132 executeFuture = CompletableFutureUtils.forwardExceptionTo(whenCompleted, executeFuture); in describeEndpoints()
136 return CompletableFutureUtils.failedFuture(t); in describeEndpoints()
214 executeFuture = CompletableFutureUtils.forwardExceptionTo(whenCompleted, executeFuture); in testDiscoveryIdentifiersRequired()
218 return CompletableFutureUtils.failedFuture(t); in testDiscoveryIdentifiersRequired()
286 executeFuture = CompletableFutureUtils.forwardExceptionTo(whenCompleted, executeFuture); in testDiscoveryOptional()
290 return CompletableFutureUtils.failedFuture(t); in testDiscoveryOptional()
366 executeFuture = CompletableFutureUtils.forwardExceptionTo(whenCompleted, executeFuture); in testDiscoveryRequired()
370 return CompletableFutureUtils.failedFuture(t); in testDiscoveryRequired()
|
| /external/aws-sdk-java-v2/services/s3/src/main/java/software/amazon/awssdk/services/s3/internal/multipart/ |
| D | CopyObjectHelper.java | 39 import software.amazon.awssdk.utils.CompletableFutureUtils;
72 CompletableFutureUtils.forwardExceptionTo(returnFuture, headFuture); in copyObject()
111 CompletableFutureUtils.forwardExceptionTo(returnFuture, createMultipartUploadFuture); in copyInParts()
147 CompletableFutureUtils.allOfExceptionForwarded(futures.toArray(new CompletableFuture[0])) in doCopyInParts()
216 CompletableFutureUtils.forwardExceptionTo(convertFuture, uploadPartCopyFuture); in sendIndividualUploadPartCopy()
235 CompletableFutureUtils.forwardExceptionTo(returnFuture, copyObjectFuture); in copyInOneChunk()
236 CompletableFutureUtils.forwardResultTo(copyObjectFuture, returnFuture); in copyInOneChunk()
|
| D | MultipartUploadHelper.java | 34 import software.amazon.awssdk.utils.CompletableFutureUtils;
73 CompletableFutureUtils.forwardExceptionTo(returnFuture, createMultipartUploadFuture); in createMultipartUpload()
109 CompletableFutureUtils.forwardExceptionTo(convertFuture, uploadPartFuture); in sendIndividualUploadPartRequest()
144 CompletableFutureUtils.forwardExceptionTo(returnFuture, putObjectResponseCompletableFuture); in uploadInOneChunk()
145 CompletableFutureUtils.forwardResultTo(putObjectResponseCompletableFuture, returnFuture); in uploadInOneChunk()
|
| /external/aws-sdk-java-v2/core/sdk-core/src/test/java/software/amazon/awssdk/core/waiters/ |
| D | AsyncWaiterTest.java | 28 import software.amazon.awssdk.utils.CompletableFutureUtils;
144 … return CompletableFutureUtils.failedFuture(new RuntimeException(NON_SUCCESS_STATE_MESSAGE)); in get()
147 return CompletableFutureUtils.failedFuture(new RuntimeException(SUCCESS_STATE_MESSAGE)); in get()
162 …return CompletableFutureUtils.failedFuture(new CompletionException(new RuntimeException(NON_SUCCES… in get()
165 …return CompletableFutureUtils.failedFuture(new CompletionException(new RuntimeException(SUCCESS_ST… in get()
|
| /external/aws-sdk-java-v2/core/sdk-core/src/main/java/software/amazon/awssdk/core/internal/http/pipeline/stages/ |
| D | AsyncExecutionFailureExceptionReportingStage.java | 27 import software.amazon.awssdk.utils.CompletableFutureUtils;
51 … throw CompletableFutureUtils.errorAsCompletionException(ThrowableUtils.asSdkException(toReport)); in execute()
56 return CompletableFutureUtils.forwardExceptionTo(executeFuture, wrappedExecute); in execute()
|
| D | AsyncBeforeTransmissionExecutionInterceptorsStage.java | 23 import software.amazon.awssdk.utils.CompletableFutureUtils;
49 return CompletableFutureUtils.forwardExceptionTo(future, input); in execute()
|
| /external/aws-sdk-java-v2/test/codegen-generated-classes-test/src/test/java/software/amazon/awssdk/services/waiters/ |
| D | WaitersAsyncFunctionalTest.java | 43 import software.amazon.awssdk.utils.CompletableFutureUtils;
112 … CompletableFutureUtils.failedFuture(SdkServiceException.builder().statusCode(404).build()); in allTypeOperationRetry_withAsyncWaiter_shouldReturnResponseAfterException()
133 …CompletableFuture<AllTypesResponse> serviceFuture1 = CompletableFutureUtils.failedFuture(SdkServic… in requestOverrideConfig_shouldTakePrecedence()
145 …CompletableFuture<AllTypesResponse> failedFuture = CompletableFutureUtils.failedFuture(new Runtime… in unexpectedException_shouldNotRetry()
191 …when(asyncClient.allTypes(any(AllTypesRequest.class))).thenReturn(CompletableFutureUtils.failedFut… in failureException_shouldThrowException()
203 …when(asyncClient.allTypes(any(AllTypesRequest.class))).thenReturn(CompletableFutureUtils.failedFut… in errorShouldNotBeWrapped()
|
| /external/aws-sdk-java-v2/core/sdk-core/src/main/java/software/amazon/awssdk/core/internal/handler/ |
| D | BaseAsyncClientHandler.java | 53 import software.amazon.awssdk.utils.CompletableFutureUtils;
212 return CompletableFutureUtils.failedFuture(e);
242 … return CompletableFutureUtils.forwardExceptionTo(exceptionTranslatedFuture, invokeFuture);
248 return CompletableFutureUtils.failedFuture(ThrowableUtils.asSdkException(t));
299 CompletableFutureUtils.forwardExceptionTo(outputFuture, apiCallResult);
304 return CompletableFutureUtils.failedFuture(e);
|
| /external/aws-sdk-java-v2/core/auth/src/main/java/software/amazon/awssdk/auth/credentials/ |
| D | TokenUtils.java | 23 import software.amazon.awssdk.utils.CompletableFutureUtils;
75 … return () -> toSdkToken(CompletableFutureUtils.joinLikeSync(identityProvider.resolveIdentity())); in toSdkTokenProvider()
|
| D | CredentialUtils.java | 22 import software.amazon.awssdk.utils.CompletableFutureUtils;
106 CompletableFutureUtils.joinLikeSync(identityProvider.resolveIdentity()); in toCredentialsProvider()
|
| /external/aws-sdk-java-v2/core/http-auth-aws/src/main/java/software/amazon/awssdk/http/auth/aws/crt/internal/signer/ |
| D | RollingSigner.java | 30 import software.amazon.awssdk.utils.CompletableFutureUtils;
57 …return CompletableFutureUtils.joinLikeSync(AwsSigner.signChunk(crtBody, previousSignature, configC… in signChunk()
73 …return CompletableFutureUtils.joinLikeSync(AwsSigner.sign(httpHeaderList, previousSignature, confi… in signTrailerHeaders()
|
| /external/aws-sdk-java-v2/services/rds/src/main/java/software/amazon/awssdk/services/rds/ |
| D | DefaultRdsUtilities.java | 35 import software.amazon.awssdk.utils.CompletableFutureUtils;
122 … CompletableFutureUtils.joinLikeSync(request.credentialsIdentityProvider().resolveIdentity())); in resolveCredentials()
126 …return CredentialUtils.toCredentials(CompletableFutureUtils.joinLikeSync(this.credentialsProvider.… in resolveCredentials()
|
| /external/aws-sdk-java-v2/utils/src/main/java/software/amazon/awssdk/utils/ |
| D | CompletableFutureUtils.java | 29 public final class CompletableFutureUtils { class
30 private static final Logger log = Logger.loggerFor(CompletableFutureUtils.class);
32 private CompletableFutureUtils() { in CompletableFutureUtils() method in CompletableFutureUtils
|