Home
last modified time | relevance | path

Searched refs:asyncClient (Results 1 – 25 of 32) sorted by relevance

12

/aosp_15_r20/external/aws-sdk-java-v2/test/codegen-generated-classes-test/src/test/java/software/amazon/awssdk/services/waiters/
H A DWaitersAsyncFunctionalTest.java48 public RestJsonWithWaitersAsyncClient asyncClient; field in WaitersAsyncFunctionalTest
53 asyncClient = mock(RestJsonWithWaitersAsyncClient.class); in setup()
55 .client(asyncClient) in setup()
65 asyncClient.close(); in cleanup()
80 when(asyncClient.allTypes(any(AllTypesRequest.class))).thenReturn(serviceFuture); in allTypeOperation_withAsyncWaiter_shouldReturnResponse()
94 when(asyncClient.allTypes(any(AllTypesRequest.class))).thenReturn(serviceFuture); in allTypeOperationFailed_withAsyncWaiter_shouldReturnException()
115 … when(asyncClient.allTypes(any(AllTypesRequest.class))).thenReturn(serviceFuture1, serviceFuture2); in allTypeOperationRetry_withAsyncWaiter_shouldReturnResponseAfterException()
136 … when(asyncClient.allTypes(any(AllTypesRequest.class))).thenReturn(serviceFuture1, serviceFuture2); in requestOverrideConfig_shouldTakePrecedence()
146 when(asyncClient.allTypes(any(AllTypesRequest.class))).thenReturn(failedFuture); in unexpectedException_shouldNotRetry()
168 when(asyncClient.allTypes(any(AllTypesRequest.class))).thenReturn(future1, future2); in unexpectedResponse_shouldRetry()
[all …]
H A DWaiterResourceTest.java35 private RestJsonWithWaitersAsyncClient asyncClient; field in WaiterResourceTest
53 .client(asyncClient) in closeAsyncWaiter_customizedClientAndExecutorServiceProvided_shouldNotClose()
/aosp_15_r20/external/aws-sdk-java-v2/test/stability-tests/src/it/java/software/amazon/awssdk/stability/tests/kinesis/
H A DKinesisStabilityTest.java73 private KinesisAsyncClient asyncClient; field in KinesisStabilityTest
85 asyncClient = KinesisAsyncClient.builder() in setup()
90 asyncClient.createStream(r -> r.streamName(streamName) in setup()
95 streamARN = asyncClient.describeStream(r -> r.streamName(streamName)).join() in setup()
99 shardIds = asyncClient.listShards(r -> r.streamName(streamName)) in setup()
111 … asyncClient.deleteStream(b -> b.streamName(streamName).enforceConsumerDeletion(true)).join(); in tearDown()
114 asyncClient.close(); in tearDown()
137 …IntFunction<CompletableFuture<?>> futureFunction = i -> asyncClient.registerStreamConsumer(r -> r.… in registerStreamConsumers()
154 i -> asyncClient.putRecord(PutRecordRequest.builder() in putRecords()
181 asyncClient.subscribeToShard(b -> b.shardId(shardIds.get(shardIndex)) in generateSubscribeToShardFutures()
[all …]
/aosp_15_r20/external/aws-sdk-java-v2/test/codegen-generated-classes-test/src/test/java/software/amazon/awssdk/services/protocolquery/
H A DMoveQueryParamsToBodyTest.java64 private ProtocolQueryAsyncClient asyncClient; field in MoveQueryParamsToBodyTest
83 if (asyncClient != null) { in teardown()
84 asyncClient.close(); in teardown()
86 asyncClient = null; in teardown()
124 asyncClient = ProtocolQueryAsyncClient.builder() in customInterceptor_asyncClient_additionalQueryParamsAdded_paramsAlsoMovedToBody()
132 asyncClient.membersInQueryParams(r -> r.stringQueryParam("hello")); in customInterceptor_asyncClient_additionalQueryParamsAdded_paramsAlsoMovedToBody()
159 asyncClient = ProtocolQueryAsyncClient.builder() in requestOverrideConfiguration_asyncClient_additionalQueryParamsAdded_paramsAlsoMovedToBody()
167 …asyncClient.membersInQueryParams(r -> r.stringQueryParam("hello").overrideConfiguration(createOver… in requestOverrideConfiguration_asyncClient_additionalQueryParamsAdded_paramsAlsoMovedToBody()
195 asyncClient = ProtocolQueryAsyncClient.builder() in asyncClient_noQueryParamsAdded_onlyContainsOriginalContent()
202 asyncClient.allTypes(r -> r.stringMember("hello")); in asyncClient_noQueryParamsAdded_onlyContainsOriginalContent()
/aosp_15_r20/external/aws-sdk-java-v2/services/kinesis/src/it/java/software/amazon/awssdk/services/kinesis/
H A DSubscribeToShardIntegrationTest.java66 asyncClient.createStream(r -> r.streamName(streamName) in setup()
69 String streamARN = asyncClient.describeStream(r -> r.streamName(streamName)).join() in setup()
73 this.shardId = asyncClient.listShards(r -> r.streamName(streamName)) in setup()
76 this.consumerArn = asyncClient.registerStreamConsumer(r -> r.streamARN(streamARN) in setup()
85 asyncClient.deleteStream(r -> r.streamName(streamName) in tearDown()
134 asyncClient.subscribeToShard(r -> r.consumerARN(consumerArn) in subscribeToShard_ReceivesAllData()
155 asyncClient.subscribeToShard(r -> r.consumerARN(consumerArn) in limitedSubscription_callCompleteMethodOfSubs_whenLimitsReached()
221 asyncClient.subscribeToShard(r -> r.consumerARN(consumerArn) in cancelledSubscription_doesNotCallCompleteMethodOfHandler()
283 Waiter.run(() -> asyncClient.describeStreamConsumer(r -> r.consumerARN(consumerArn)).join()) in waitForConsumerToBeActive()
289 Waiter.run(() -> asyncClient.describeStream(r -> r.streamName(streamName)).join()) in waitForStreamToBeActive()
[all …]
H A DAbstractTestCase.java30 protected static KinesisAsyncClient asyncClient; field in AbstractTestCase
38 …asyncClient = KinesisAsyncClient.builder().credentialsProvider(CREDENTIALS_PROVIDER_CHAIN).build(); in init()
/aosp_15_r20/external/aws-sdk-java-v2/test/codegen-generated-classes-test/src/test/java/software/amazon/awssdk/services/
H A DHttpChecksumValidationTest.java69 private ProtocolRestJsonAsyncClient asyncClient; field in HttpChecksumValidationTest
87 asyncClient = ProtocolRestJsonAsyncClient.builder() in setupClient()
241 …asyncClient.getOperationWithChecksum(r -> r.checksumMode(ChecksumMode.ENABLED), AsyncResponseTrans… in asyncClientValidateStreamingResponse()
252 …asyncClient.getOperationWithChecksum(r -> r.checksumMode(ChecksumMode.ENABLED), AsyncResponseTrans… in asyncClientValidateStreamingResponseZeroByte()
263 asyncClient.operationWithChecksumNonStreaming( in asyncClientValidateNonStreamingResponse()
279 asyncClient.operationWithChecksumNonStreaming( in asyncClientValidateNonStreamingResponseZeroByte()
295 asyncClient.getOperationWithChecksum( in asyncClientValidateStreamingResponseForceSkip()
309 asyncClient.getOperationWithChecksum( in asyncClientValidateStreamingResponseNoAlgorithmInResponse()
322 asyncClient.getOperationWithChecksum( in asyncClientValidateStreamingResponseNoAlgorithmFoundInClient()
335 .isThrownBy(() -> asyncClient.getOperationWithChecksum( in asyncClientValidateStreamingResponseWithValidationFailed()
[all …]
H A DAsyncRequestCompressionTest.java50 private ProtocolRestJsonAsyncClient asyncClient; field in AsyncRequestCompressionTest
56 asyncClient = ProtocolRestJsonAsyncClient.builder() in setUp()
83 asyncClient.putOperationWithRequestCompression(request); in asyncNonStreamingOperation_compressionEnabledThresholdOverridden_compressesCorrectly()
104 asyncClient.putOperationWithRequestCompression(request); in asyncNonStreamingOperation_payloadSizeLessThanCompressionThreshold_doesNotCompress()
123 …asyncClient.putOperationWithStreamingRequestCompression(request, customAsyncRequestBodyWithoutCont… in asyncStreamingOperation_compressionEnabled_compressesCorrectly()
147 asyncClient.putOperationWithRequestCompression(request); in asyncNonStreamingOperation_compressionEnabledThresholdOverriddenWithRetry_compressesCorrectly()
167 …asyncClient.putOperationWithStreamingRequestCompression(request, customAsyncRequestBodyWithoutCont… in asyncStreamingOperation_compressionEnabledWithRetry_compressesCorrectly()
H A DHostPrefixTest.java44 private ProtocolRestJsonAsyncClient asyncClient; field in HostPrefixTest
58 asyncClient = ProtocolRestJsonAsyncClient.builder() in setupClient()
73 … assertThatThrownBy(() -> asyncClient.operationWithHostPrefix(b -> b.stringMember("123#")).join()) in invalidHostPrefix_shouldThrowException()
82 assertThatThrownBy(() -> asyncClient.operationWithHostPrefix(SdkBuilder::build).join()) in nullHostPrefix_shouldThrowException()
105 asyncClient.operationWithHostPrefix(b -> b.stringMember("123")).join(); in asyncValidHostPrefix_shouldPrefixEndpoint()
H A DAsyncRequestBodyFlexibleChecksumInTrailerTest.java76 private ProtocolRestJsonAsyncClient asyncClient; field in AsyncRequestBodyFlexibleChecksumInTrailerTest
97 asyncClient = ProtocolRestJsonAsyncClient.builder() in setupClient()
118 …asyncClient.putOperationWithChecksum(b -> b.checksumAlgorithm(ChecksumAlgorithm.CRC32), AsyncReque… in asyncStreaming_NoSigner_shouldContainChecksum_fromInterceptors()
134 …asyncClient.putOperationWithChecksum(b -> b.checksumAlgorithm(ChecksumAlgorithm.CRC32).contentEnco… in asyncStreaming_NoSigner_shouldContainChecksum_fromInterceptors_withContentEncoding()
159 …asyncClient.putOperationWithChecksum(b -> b.checksumAlgorithm(ChecksumAlgorithm.SHA256), AsyncRequ… in asyncStreaming_withRetry_NoSigner_shouldContainChecksum_fromInterceptors()
183 asyncClient.putOperationWithChecksum(b -> b.checksumAlgorithm(ChecksumAlgorithm.CRC32), in asyncStreaming_FromAsyncRequestBody_VariableChunkSize_NoSigner_addsChecksums_fromInterceptors()
207 asyncClient.putOperationWithChecksum(b -> b.checksumAlgorithm(ChecksumAlgorithm.CRC32), in asyncStreaming_withRetry_FromAsyncRequestBody_VariableChunkSize_NoSigner_addsChecksums_fromInterceptors()
H A DEndpointDiscoveryRequestOverrideConfigTest.java44 private EndpointDiscoveryTestAsyncClient asyncClient; field in EndpointDiscoveryRequestOverrideConfigTest
63 asyncClient = EndpointDiscoveryTestAsyncClient.builder() in setupClient()
87 asyncClient.testDiscoveryRequired(r -> {}).get(10, TimeUnit.SECONDS); in asyncClientCredentialsUsedByDefault()
101 …asyncClient.testDiscoveryRequired(r -> r.overrideConfiguration(c -> c.credentialsProvider(() -> RE… in asyncClientRequestCredentialsUsedIfOverridden()
116 … asyncClient.testDiscoveryRequired(r -> r.overrideConfiguration(c -> c.putHeader("Foo", "Bar"))) in asyncClientRequestHeadersUsed()
H A DEndpointDiscoveryTest.java66 private EndpointDiscoveryTestAsyncClient asyncClient; field in EndpointDiscoveryTest
84 asyncClient = EndpointDiscoveryTestAsyncClient.builder() in setupClient()
168 asyncClient.testDiscoveryRequired(r -> { in assertAsyncRequiredOperationCallThrowable()
/aosp_15_r20/external/aws-sdk-java-v2/services/apigateway/src/test/java/software/amazon/awssdk/services/apigateway/model/
H A DGetUsageRequestTest.java50 private ApiGatewayAsyncClient asyncClient; field in GetUsageRequestTest
63 asyncClient = ApiGatewayAsyncClient.builder() in setUp()
106 assertThatNoException().isThrownBy(() -> asyncClient.getUsage(request).join()); in marshall_asyncMissingStartDateButValidationDisabled_ThrowsException()
114 asyncClient.getUsage(request).join(); in marshall_asyncEmptyStartDate_encodesAsEmptyValue()
124 asyncClient.getUsage(request).join(); in marshall_asyncNonEmptyStartDate_encodesValue()
/aosp_15_r20/external/aws-sdk-java-v2/codegen/src/main/java/software/amazon/awssdk/codegen/model/intermediate/
H A DMetadata.java48 private String asyncClient; field in Metadata
273 return asyncClient; in getAsyncClient()
276 public void setAsyncClient(String asyncClient) { in setAsyncClient() argument
277 this.asyncClient = asyncClient; in setAsyncClient()
280 public Metadata withAsyncClient(String asyncClient) { in withAsyncClient() argument
281 setAsyncClient(asyncClient); in withAsyncClient()
/aosp_15_r20/external/aws-sdk-java-v2/test/protocol-tests/src/test/java/software/amazon/awssdk/protocol/tests/
H A DQueryMetadataTest.java47 private ProtocolQueryAsyncClient asyncClient; field in QueryMetadataTest
57 asyncClient = ProtocolQueryAsyncClient.builder() in setupClient()
74 AllTypesResponse allTypesResponse = asyncClient.allTypes(SdkBuilder::build).join(); in asyncResponse_shouldContainResponseMetadata()
81 AllTypesResponse allTypesResponse = asyncClient.allTypes(SdkBuilder::build).join(); in requestIdInHeaderButNotXml_ShouldContainsResponseMetadata()
H A DSdkHttpResponseTest.java65 private ProtocolRestJsonAsyncClient asyncClient; field in SdkHttpResponseTest
82 asyncClient = ProtocolRestJsonAsyncClient.builder() in setupClient()
113 AllTypesResponse response = asyncClient.allTypes(b -> b.simpleList("test")).join(); in asyncNonStreamingShouldContainsSdkHttpData()
122 ResponseBytes<StreamingOutputOperationResponse> responseBytes = asyncClient in asyncStreamingMethodShouldContainSdkHttpDate()
H A DXmlMetadataTest.java47 private ProtocolRestXmlAsyncClient asyncClient; field in XmlMetadataTest
57 asyncClient = ProtocolRestXmlAsyncClient.builder() in setupClient()
67 AllTypesResponse allTypesResponse = asyncClient.allTypes(SdkBuilder::build).join(); in requestIdInHeaderButNotXml_ShouldContainsResponseMetadata()
H A DQueryRequestTransformTest.java47 private ProtocolQueryAsyncClient asyncClient; field in QueryRequestTransformTest
58 asyncClient = ProtocolQueryAsyncClient.builder() in setupClient()
78 asyncClient.idempotentOperation(request).join(); in asyncRequest_isMovingParamsToBodyStage()
/aosp_15_r20/external/aws-sdk-java-v2/test/codegen-generated-classes-test/src/test/java/software/amazon/awssdk/services/customresponsemetadata/
H A DCustomResponseMetadataTest.java50 private ProtocolRestJsonAsyncClient asyncClient; field in CustomResponseMetadataTest
60 asyncClient = ProtocolRestJsonAsyncClient.builder() in setupClient()
85 AllTypesResponse allTypesResponse = asyncClient.allTypes(SdkBuilder::build).join(); in asyncNonStreaming_shouldContainResponseMetadata()
93 … asyncClient.streamingOutputOperation(SdkBuilder::build, AsyncResponseTransformer.toBytes()); in asyncStreaming_shouldContainResponseMetadata()
/aosp_15_r20/external/aws-sdk-java-v2/test/codegen-generated-classes-test/src/test/java/software/amazon/awssdk/services/awsquerycompatible/
H A DAwsQueryCompatibleErrorTest.java46 private QueryCompatibleJsonAsyncClient asyncClient; field in AwsQueryCompatibleErrorTest
64 asyncClient = QueryCompatibleJsonAsyncClient.builder() in setupClient()
97 assertThatThrownBy(() -> asyncClient.allType(r -> { in verifyAsyncClientException_invalidHeader_shouldRetrievedFromContent()
105 assertThatThrownBy(() -> asyncClient.allType(r -> { in verifyAsyncClientException_emptyHeader_shouldRetrievedFromContent()
/aosp_15_r20/external/aws-sdk-java-v2/test/module-path-tests/src/main/java/software/amazon/awssdk/modulepath/tests/mocktests/
H A DXmlProtocolApiCall.java27 private ProtocolRestXmlAsyncClient asyncClient; field in XmlProtocolApiCall
32 asyncClient = ProtocolRestXmlAsyncClient.builder().httpClient(mockAyncHttpClient).build(); in XmlProtocolApiCall()
42 return () -> asyncClient.allTypes().join(); in asyncRunnable()
H A DJsonProtocolApiCall.java33 private ProtocolRestJsonAsyncClient asyncClient; field in JsonProtocolApiCall
43 this.asyncClient = ProtocolRestJsonAsyncClient.builder() in JsonProtocolApiCall()
59 return () -> asyncClient.allTypes().join(); in asyncRunnable()
/aosp_15_r20/external/aws-sdk-java-v2/test/protocol-tests/src/test/java/software/amazon/awssdk/protocol/tests/clockskew/
H A DClockSkewAdjustmentTest.java62 private ProtocolJsonRpcAsyncClient asyncClient; field in ClockSkewAdjustmentTest
68 asyncClient = createAsyncClient(1); in setupClient()
127 …assertNoAdjust(clientTime, serviceTime, statusCode, errorCode, () -> asyncClient.allTypes().join()… in assertNoAdjust()
132 assertAdjusts(serviceTime, statusCode, errorCode, () -> asyncClient.allTypes().join()); in assertAdjusts()
/aosp_15_r20/external/aws-sdk-java-v2/test/codegen-generated-classes-test/src/test/java/software/amazon/awssdk/services/customizeduseragent/
H A DInternalUserAgentTest.java48 private ProtocolRestJsonWithInternalConfigAsyncClient asyncClient; field in InternalUserAgentTest
66 asyncClient = ProtocolRestJsonWithInternalConfigAsyncClient.builder() in setupClient()
90 asyncClient.oneOperation(SdkBuilder::build).join(); in asyncWithInternalUserAgent_shouldContainInternalUserAgent()
/aosp_15_r20/external/aws-sdk-java-v2/services/mediastoredata/src/it/java/software/amazon/awssdk/services/mediastoredata/
H A DRequestCompressionStreamingIntegrationTest.java53 private static MediaStoreDataAsyncClient asyncClient; field in RequestCompressionStreamingIntegrationTest
82 asyncClient = MediaStoreDataAsyncClient.builder() in setup()
136 asyncClient.putObject(putObjectRequest, asyncRequestBody).join(); in putObject_withAsyncStreamingRequestCompression_compressesPayloadAndSendsCorrectly()

12