Fix test after throw change

Author: dagnir

core/http-auth-aws/src/test/java/software/amazon/awssdk/http/auth/aws/internal/signer/AwsChunkedV4PayloadSignerTest.java

@@ -17,6 +17,7 @@
 
 import static org.assertj.core.api.Assertions.assertThat;
 import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assumptions.assumeFalse;
 import static software.amazon.awssdk.checksums.DefaultChecksumAlgorithm.CRC32;
 import static software.amazon.awssdk.checksums.DefaultChecksumAlgorithm.SHA256;
 
@@ -360,6 +361,8 @@ void sign_withPreExistingTrailersAndChecksumAndSignedPayload_shouldAwsChunkEncod
     @ParameterizedTest(name = "{0}")
     @MethodSource("signingImpls")
     void sign_withoutContentLength_calculatesContentLengthFromPayload(String name, SigningImplementation impl) {
+        assumeFalse("ASYNC".equalsIgnoreCase(name), "The async path disallows unknown content length");
+
         String expectedContent =
             "4\r\n{\"Ta\r\n" +
             "4\r\nbleN\r\n" +

core/http-auth-aws/src/test/java/software/amazon/awssdk/http/auth/aws/internal/signer/util/SignerUtilsTest.java

@@ -16,6 +16,7 @@
 package software.amazon.awssdk.http.auth.aws.internal.signer.util;
 
 import static org.assertj.core.api.Assertions.assertThat;
+import static org.assertj.core.api.Assertions.assertThatThrownBy;
 import static software.amazon.awssdk.http.Header.CONTENT_LENGTH;
 import static software.amazon.awssdk.http.auth.aws.internal.signer.util.SignerConstant.X_AMZ_DECODED_CONTENT_LENGTH;
 
@@ -109,23 +110,16 @@ void computeAndMoveContentLength_async_contentLengthPresent_shouldNotSubscribeTo
         assertThat(request.firstMatchingHeader(X_AMZ_DECODED_CONTENT_LENGTH)).contains("10");
     }
 
-    @ParameterizedTest
-    @MethodSource("publishers")
-    void computeAndMoveContentLength_contentLengthNotPresent_shouldInvokeSubscribe(Flowable<ByteBuffer> publisher, long expectedLength) {
+    @Test
+    void computeAndMoveContentLength_contentLengthNotPresent_throws() {
         SdkHttpRequest.Builder request = SdkHttpRequest.builder();
 
-        if (publisher != null) {
-            publisher = Mockito.spy(publisher);
-        }
-
-        SignerUtils.computeAndMoveContentLength(request, publisher).join();
+        Publisher<ByteBuffer> contentPublisher = Flowable.just(ByteBuffer.wrap("content".getBytes(StandardCharsets.UTF_8)));
 
-        if (publisher != null) {
-            Mockito.verify(publisher, Mockito.times(1)).subscribe(Mockito.any(Subscriber.class));
-        }
+        assertThatThrownBy(() -> SignerUtils.computeAndMoveContentLength(request, contentPublisher).join())
+            .isInstanceOf(UnsupportedOperationException.class)
+            .hasMessage("Content-Length header must be specified");
 
-        assertThat(request.firstMatchingHeader(CONTENT_LENGTH)).isEmpty();
-        assertThat(request.firstMatchingHeader(X_AMZ_DECODED_CONTENT_LENGTH)).contains(String.valueOf(expectedLength));
     }
 
     public static Stream<Arguments> streams() {