Merge branch 'dongie/sra-chunk-encoding-pt2' into dongie/sra-chunk-encoding-pt2-additional-testing

Author: dagnir

core/crt-core/src/main/java/software/amazon/awssdk/crtcore/CrtRequestBodyAdapter.java

@@ -17,12 +17,12 @@
 
 import java.nio.ByteBuffer;
 import org.reactivestreams.Publisher;
-import software.amazon.awssdk.annotations.SdkInternalApi;
+import software.amazon.awssdk.annotations.SdkProtectedApi;
 import software.amazon.awssdk.crt.http.HttpRequestBodyStream;
 import software.amazon.awssdk.utils.async.ByteBufferStoringSubscriber;
 import software.amazon.awssdk.utils.async.ByteBufferStoringSubscriber.TransferResult;
 
-@SdkInternalApi
+@SdkProtectedApi
 public final class CrtRequestBodyAdapter implements HttpRequestBodyStream {
     private static final int BUFFER_SIZE = 4 * 1024 * 1024; // 4 MB
     private final Publisher<ByteBuffer> requestPublisher;

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

@@ -22,6 +22,7 @@
 import software.amazon.awssdk.annotations.SdkInternalApi;
 import software.amazon.awssdk.crt.http.HttpHeader;
 import software.amazon.awssdk.crt.http.HttpRequest;
+import software.amazon.awssdk.crtcore.CrtRequestBodyAdapter;
 import software.amazon.awssdk.http.Header;
 import software.amazon.awssdk.http.HttpExecuteRequest;
 import software.amazon.awssdk.http.SdkHttpRequest;
@@ -54,6 +55,7 @@ public static HttpRequest toAsyncCrtRequest(CrtAsyncRequestContext request) {
                                encodedPath + encodedQueryString,
                                crtHeaderArray,
                                new CrtRequestBodyAdapter(sdkExecuteRequest.requestContentPublisher(),
+                                                         sdkExecuteRequest.requestContentPublisher().contentLength().orElse(0L),
                                                          request.readBufferSize()));
     }