Added AWS CRT SDK Test

Author: aneesh-neelam

build.gradle

@@ -8,6 +8,7 @@ ext {
     monoReactorVersion = '3.6.9'
     aws1SdkVersion = '1.12.770'
     aws2SdkVersion = '2.27.9'
+    awsCrtSdkVersion = '0.30.8'
     junitJupiterVersion = '5.11.0'
     testContainersVersion = '1.20.1'
 }
@@ -54,6 +55,7 @@ dependencies {
 
     // AWS SDK v2 for running Tests
     testImplementation group: 'software.amazon.awssdk', name: 's3', version: aws2SdkVersion
+    testImplementation group: 'software.amazon.awssdk.crt', name: 'aws-crt', version: awsCrtSdkVersion
 }
 
 test {

src/test/java/S3ObjectIteratorContainerTest.java

@@ -57,6 +57,7 @@ public class S3ObjectIteratorContainerTest {
     private AmazonS3 amazonS3;
     private S3Client s3Client;
     private S3AsyncClient s3AsyncClient;
+    private S3AsyncClient s3AsyncCrtClient;
 
     @BeforeAll
     public static void beforeAll() {
@@ -85,6 +86,11 @@ public void setUp() {
                 .region(Region.of(awsRegion))
                 .credentialsProvider(StaticCredentialsProvider.create(AwsBasicCredentials.create(awsAccessKey, awsSecretKey)))
                 .build();
+        this.s3AsyncCrtClient = S3AsyncClient.crtBuilder()
+                .endpointOverride(awsS3Uri)
+                .region(Region.of(awsRegion))
+                .credentialsProvider(StaticCredentialsProvider.create(AwsBasicCredentials.create(awsAccessKey, awsSecretKey)))
+                .build();
 
         if (createS3Bucket) {
             CreateBucketResponse response = this.s3Client.createBucket(r -> r.bucket(s3BucketName));
@@ -135,6 +141,19 @@ public void testS3ObjectIteratorAsync() {
         Assertions.assertEquals(s3ObjectCount, count);
     }
 
+    @Test
+    public void testS3ObjectIteratorAsyncCrt() {
+        System.out.println("Testing: " + AsyncS3ObjectIterator.class.getCanonicalName());
+        ListObjectsV2Request listObjectsV2Request = ListObjectsV2Request.builder()
+                .bucket(s3BucketName)
+                .prefix(s3KeyPrefix)
+                .build();
+        AsyncS3ObjectIterator asyncS3ObjectIterator = new AsyncS3ObjectIterator(this.s3AsyncCrtClient, listObjectsV2Request, Duration.ofSeconds(30));
+        long count = StreamSupport.stream(Spliterators.spliteratorUnknownSize(asyncS3ObjectIterator, Spliterator.ORDERED), false)
+                .count();
+        Assertions.assertEquals(s3ObjectCount, count);
+    }
+
     @Test
     public void testS3ObjectSummaryIterator() {
         System.out.println("Testing: " + S3ObjectSummaryIterator.class.getCanonicalName());