| /aosp_15_r20/external/aws-sdk-java-v2/services/sqs/src/test/java/software/amazon/awssdk/services/sqs/ |
| H A D | MessageMD5ChecksumValidationDisableTest.java | 48 private MockAsyncHttpClient asyncHttpClient; field in MessageMD5ChecksumValidationDisableTest
53 asyncHttpClient = new MockAsyncHttpClient(); in setupClient()
59 asyncHttpClient.reset(); in cleanup()
65 asyncHttpClient.stubResponses(responseWithMd5()); in md5ValidationEnabled_default_md5InResponse_Works()
68 .httpClient(asyncHttpClient) in md5ValidationEnabled_default_md5InResponse_Works()
79 asyncHttpClient.stubResponses(responseWithoutMd5()); in md5ValidationEnabled_default_noMd5InResponse_throwsException()
82 .httpClient(asyncHttpClient) in md5ValidationEnabled_default_noMd5InResponse_throwsException()
93 asyncHttpClient.stubResponses(responseWithMd5()); in md5ValidationDisabled_md5InResponse_Works()
96 .httpClient(asyncHttpClient) in md5ValidationDisabled_md5InResponse_Works()
108 asyncHttpClient.stubResponses(responseWithoutMd5()); in md5ValidationDisabled_noMd5InResponse_Works()
[all …]
|
| /aosp_15_r20/external/aws-sdk-java-v2/test/codegen-generated-classes-test/src/test/java/software/amazon/awssdk/services/ |
| H A D | EndpointDiscoveryRequestOverrideConfigTest.java | 46 private MockAsyncHttpClient asyncHttpClient; field in EndpointDiscoveryRequestOverrideConfigTest
54 asyncHttpClient = new MockAsyncHttpClient(); in setupClient()
67 .httpClient(asyncHttpClient) in setupClient()
74 asyncHttpClient.reset(); in cleanup()
86 asyncHttpClient.stubResponses(successfulEndpointDiscoveryResponse(), successfulResponse()); in asyncClientCredentialsUsedByDefault()
88 assertRequestsUsedCredentials(asyncHttpClient.getRequests(), CLIENT_CREDENTIALS); in asyncClientCredentialsUsedByDefault()
100 asyncHttpClient.stubResponses(successfulEndpointDiscoveryResponse(), successfulResponse()); in asyncClientRequestCredentialsUsedIfOverridden()
103 assertRequestsUsedCredentials(asyncHttpClient.getRequests(), REQUEST_CREDENTIALS); in asyncClientRequestCredentialsUsedIfOverridden()
115 asyncHttpClient.stubResponses(successfulEndpointDiscoveryResponse(), successfulResponse()); in asyncClientRequestHeadersUsed()
118 assertRequestsHadHeader(asyncHttpClient.getRequests(), "Foo", "Bar"); in asyncClientRequestHeadersUsed()
|
| /aosp_15_r20/external/aws-sdk-java-v2/core/sdk-core/src/test/java/utils/ |
| H A D | HttpTestUtils.java | 58 return new TestAsyncClientBuilder().asyncHttpClient(testSdkAsyncHttpClient()).build(); in testAsyncHttpClient()
144 private SdkAsyncHttpClient asyncHttpClient; field in HttpTestUtils.TestAsyncClientBuilder
154 public TestAsyncClientBuilder asyncHttpClient(SdkAsyncHttpClient asyncHttpClient) { in asyncHttpClient() method in HttpTestUtils.TestAsyncClientBuilder
155 this.asyncHttpClient = asyncHttpClient; in asyncHttpClient()
175 …SdkAsyncHttpClient asyncHttpClient = this.asyncHttpClient != null ? this.asyncHttpClient : testSdk… in build() local
177 … .option(SdkClientOption.ASYNC_HTTP_CLIENT, asyncHttpClient) in build()
|
| /aosp_15_r20/external/aws-sdk-java-v2/test/old-client-version-compatibility-test/src/test/java/ |
| H A D | S3AnonymousTest.java | 37 private MockAsyncHttpClient asyncHttpClient; field in S3AnonymousTest
46 this.asyncHttpClient = new MockAsyncHttpClient(); in setup()
47 this.asyncHttpClient.stubNextResponse200(); in setup()
58 .httpClient(asyncHttpClient) in setup()
65 asyncHttpClient.close(); in teardown()
79 assertThat(asyncHttpClient.getLastRequest().firstMatchingHeader("Authorization")).isEmpty(); in nonStreamingOperations_async_canBeAnonymous()
91 assertThat(asyncHttpClient.getLastRequest().firstMatchingHeader("Authorization")).isEmpty(); in streamingWriteOperations_async_canBeAnonymous()
103 assertThat(asyncHttpClient.getLastRequest().firstMatchingHeader("Authorization")).isEmpty(); in streamingReadOperations_async_canBeAnonymous()
|
| H A D | InterceptorSignerAttributeTest.java | 145 MockAsyncHttpClient asyncHttpClient = new MockAsyncHttpClient()) { in test()
146 stub200Responses(httpClient, asyncHttpClient); in test()
149 … S3AsyncClientBuilder s3AsyncBuilder = createS3AsyncBuilder(configBuilder, asyncHttpClient); in test()
171 … static void stub200Responses(MockSyncHttpClient httpClient, MockAsyncHttpClient asyncHttpClient) { in stub200Responses() argument
179 asyncHttpClient.stubResponses(response); in stub200Responses()
190 …ncBuilder(ClientOverrideConfiguration.Builder configBuilder, MockAsyncHttpClient asyncHttpClient) { in createS3AsyncBuilder() argument
194 .httpClient(asyncHttpClient) in createS3AsyncBuilder()
|
| /aosp_15_r20/external/aws-sdk-java-v2/test/ruleset-testing-core/src/main/java/software/amazon/awssdk/core/rules/testing/ |
| H A D | BaseRuleSetClientTest.java | 56 private static SdkAsyncHttpClient asyncHttpClient; field in BaseRuleSetClientTest
61 asyncHttpClient = mock(SdkAsyncHttpClient.class); in setup()
66 reset(syncHttpClient, asyncHttpClient); in methodSetup()
69 when(asyncHttpClient.execute(any())).thenAnswer(i -> { in methodSetup()
114 verify(asyncHttpClient).execute(requestCaptor.capture()); in runAndVerify()
129 return asyncHttpClient; in getAsyncHttpClient()
|
| /aosp_15_r20/external/aws-sdk-java-v2/services/s3/src/test/java/software/amazon/awssdk/services/s3/ |
| H A D | ExecutionAttributeBackwardsCompatibilityTest.java | 144 MockAsyncHttpClient asyncHttpClient = new MockAsyncHttpClient()) { in test()
145 stub200Responses(httpClient, asyncHttpClient); in test()
148 … S3AsyncClientBuilder s3AsyncBuilder = createS3AsyncBuilder(configBuilder, asyncHttpClient); in test()
166 … static void stub200Responses(MockSyncHttpClient httpClient, MockAsyncHttpClient asyncHttpClient) { in stub200Responses() argument
174 asyncHttpClient.stubResponses(response); in stub200Responses()
185 …ncBuilder(ClientOverrideConfiguration.Builder configBuilder, MockAsyncHttpClient asyncHttpClient) { in createS3AsyncBuilder() argument
189 .httpClient(asyncHttpClient) in createS3AsyncBuilder()
|
| /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 | ApplyUserAgentStage.java | 67 SdkAsyncHttpClient asyncHttpClient, in resolveClientUserAgent() argument
101 … .append(SdkHttpUtils.urlEncode(clientName(clientType, syncHttpClient, asyncHttpClient))); in resolveClientUserAgent()
143 …ientName(ClientType clientType, SdkHttpClient syncHttpClient, SdkAsyncHttpClient asyncHttpClient) { in clientName() argument
149 return asyncHttpClient == null ? "null" : asyncHttpClient.clientName(); in clientName()
|
| /aosp_15_r20/external/aws-sdk-java-v2/services/s3/src/test/java/software/amazon/awssdk/services/s3/internal/crt/ |
| H A D | S3CrtAsyncHttpClientTest.java | 66 private S3CrtAsyncHttpClient asyncHttpClient; field in S3CrtAsyncHttpClientTest
88 asyncHttpClient = new S3CrtAsyncHttpClient(s3Client, in methodSetup()
151 CompletableFuture<Void> future = asyncHttpClient.execute(asyncExecuteRequest); in cancelRequest_shouldForwardCancellation()
252 asyncHttpClient = new S3CrtAsyncHttpClient(s3Client, S3CrtAsyncHttpClient.builder() in operationWithResponseAlgorithms_optOutValidationFromClient_shouldHonor()
279 asyncHttpClient = new S3CrtAsyncHttpClient(s3Client, S3CrtAsyncHttpClient.builder() in operationWithResponseAlgorithms_optInFromRequest_shouldHonor()
297 asyncHttpClient.execute(asyncExecuteRequest); in makeRequest()
369 asyncHttpClient.close(); in closeHttpClient_shouldCloseUnderlyingResources()
|
| /aosp_15_r20/external/aws-sdk-java-v2/core/sdk-core/src/test/java/software/amazon/awssdk/core/client/ |
| H A D | AsyncClientHandlerExceptionTest.java | 67 private final SdkAsyncHttpClient asyncHttpClient = mock(SdkAsyncHttpClient.class); field in AsyncClientHandlerExceptionTest
88 .option(SdkClientOption.ASYNC_HTTP_CLIENT, asyncHttpClient) in methodSetup()
102 …when(asyncHttpClient.execute(any(AsyncExecuteRequest.class))).thenAnswer((Answer<CompletableFuture… in methodSetup()
|
| H A D | AsyncClientHandlerInterceptorExceptionTest.java | 73 private final SdkAsyncHttpClient asyncHttpClient = mock(SdkAsyncHttpClient.class); field in AsyncClientHandlerInterceptorExceptionTest
106 .option(SdkClientOption.ASYNC_HTTP_CLIENT, asyncHttpClient) in testSetup()
139 when(asyncHttpClient.execute(any(AsyncExecuteRequest.class))) in testSetup()
|