Update to new API

Author: alexw91

http-clients/aws-crt-client/pom.xml

@@ -33,7 +33,7 @@
         <dependency>
             <groupId>software.amazon.awssdk.crt</groupId>
             <artifactId>aws-crt</artifactId>
-            <version>0.3.19</version>
+            <version>0.3.22</version>
         </dependency>
 
         <!--SDK dependencies-->

http-clients/aws-crt-client/src/main/java/software/amazon/awssdk/http/crt/AwsCrtAsyncHttpClient.java

@@ -32,7 +32,6 @@
 import software.amazon.awssdk.crt.http.HttpConnectionPoolManager;
 import software.amazon.awssdk.crt.http.HttpHeader;
 import software.amazon.awssdk.crt.http.HttpRequest;
-import software.amazon.awssdk.crt.http.HttpRequestOptions;
 import software.amazon.awssdk.crt.io.ClientBootstrap;
 import software.amazon.awssdk.crt.io.SocketOptions;
 import software.amazon.awssdk.crt.io.TlsCipherPreference;
@@ -135,7 +134,10 @@ public String clientName() {
     private HttpConnectionPoolManager createConnectionPool(URI uri) {
         Validate.notNull(uri, "URI must not be null");
         log.debug(() -> "Creating ConnectionPool for: URI:" + uri + ", MaxConns: " + maxConnectionsPerEndpoint);
-        return new HttpConnectionPoolManager(bootstrap, socketOptions, tlsContext, uri, windowSize, maxConnectionsPerEndpoint);
+
+        return new HttpConnectionPoolManager(bootstrap, socketOptions, tlsContext, uri,
+                                                HttpConnectionPoolManager.DEFAULT_MAX_BUFFER_SIZE, windowSize,
+                                                maxConnectionsPerEndpoint);
     }
 
     private HttpConnectionPoolManager getOrCreateConnectionPool(URI uri) {
@@ -225,9 +227,6 @@ public CompletableFuture<Void> execute(AsyncExecuteRequest asyncRequest) {
 
         CompletableFuture<Void> requestFuture = new CompletableFuture<>();
 
-
-        HttpRequestOptions reqOptions = new HttpRequestOptions();
-
         // When a Connection is ready from the Connection Pool, schedule the Request on the connection
         crtConnPool.acquireConnection()
             .whenComplete((crtConn, throwable) -> {
@@ -241,7 +240,7 @@ public CompletableFuture<Void> execute(AsyncExecuteRequest asyncRequest) {
                         new AwsCrtAsyncHttpStreamAdapter(crtConn, requestFuture, asyncRequest, windowSize);
 
                 // Submit the Request on this Connection
-                invokeSafely(() -> crtConn.makeRequest(crtRequest, reqOptions, crtToSdkAdapter));
+                invokeSafely(() -> crtConn.makeRequest(crtRequest, crtToSdkAdapter));
             });
 
         return requestFuture;

http-clients/aws-crt-client/src/main/java/software/amazon/awssdk/http/crt/internal/AwsCrtAsyncHttpStreamAdapter.java

@@ -80,16 +80,11 @@ public void onResponseHeaders(HttpStream stream, int responseStatusCode, HttpHea
     }
 
     @Override
-    public void onResponseHeadersDone(HttpStream stream, boolean hasBody) {
+    public void onResponseHeadersDone(HttpStream stream, int headerType) {
         initRespBodyPublisherIfNeeded(stream);
 
         respBuilder.statusCode(stream.getResponseStatusCode());
         sdkRequest.responseHandler().onHeaders(respBuilder.build());
-
-        if (!hasBody) {
-            respBodyPublisher.setQueueComplete();
-        }
-
         sdkRequest.responseHandler().onStream(respBodyPublisher);
     }
 

test/sdk-benchmarks/pom.xml

@@ -193,7 +193,7 @@
         <dependency>
             <groupId>software.amazon.awssdk.crt</groupId>
             <artifactId>aws-crt</artifactId>
-            <version>0.3.17</version>
+            <version>0.3.22</version>
             <scope>compile</scope>
         </dependency>
         <dependency>