Fix Publisher.subscribe running check and add the metadata information such as name, description to the protocol poms

Author: zoewangg

core/sdk-core/src/main/java/software/amazon/awssdk/core/internal/http/async/SimpleHttpContentPublisher.java

@@ -62,12 +62,14 @@ private SubscriptionImpl(Subscriber<? super ByteBuffer> s) {
 
         @Override
         public void request(long n) {
-            if (n <= 0) {
-                s.onError(new IllegalArgumentException("Demand must be positive"));
-            } else if (running) {
-                s.onNext(ByteBuffer.wrap(content));
-                s.onComplete();
+            if (running) {
                 running = false;
+                if (n <= 0) {
+                    s.onError(new IllegalArgumentException("Demand must be positive"));
+                } else {
+                    s.onNext(ByteBuffer.wrap(content));
+                    s.onComplete();
+                }
             }
         }
 

http-clients/netty-nio-client/src/main/java/software/amazon/awssdk/http/nio/netty/internal/ResponseHandler.java

@@ -310,14 +310,15 @@ public void subscribe(Subscriber<? super ByteBuffer> subscriber) {
             subscriber.onSubscribe(new Subscription() {
                 @Override
                 public void request(long l) {
-                    if (l <= 0 && running) {
+                    if (running) {
                         running = false;
-                        subscriber.onError(new IllegalArgumentException("Demand must be positive!"));
-                    } else if (running) {
-                        running = false;
-                        subscriber.onNext(fullContent);
-                        subscriber.onComplete();
-                        executeFuture.complete(null);
+                        if (l <= 0) {
+                            subscriber.onError(new IllegalArgumentException("Demand must be positive!"));
+                        } else {
+                            subscriber.onNext(fullContent);
+                            subscriber.onComplete();
+                            executeFuture.complete(null);
+                        }
                     }
                 }
 

protocols/aws-cbor-protocol/pom.xml

@@ -10,6 +10,10 @@
     <modelVersion>4.0.0</modelVersion>
 
     <artifactId>aws-cbor-protocol</artifactId>
+    <name>AWS Java SDK :: AWS Cbor Protocol</name>
+    <description>The AWS SDK for Java - module holds the classes for AWS Cbor protocol
+    </description>
+    <url>https://aws.amazon.com/sdkforjava</url>
 
     <dependencies>
         <dependency>

protocols/aws-ion-protocol/pom.xml

@@ -10,6 +10,10 @@
     <modelVersion>4.0.0</modelVersion>
 
     <artifactId>aws-ion-protocol</artifactId>
+    <name>AWS Java SDK :: AWS Ion Protocol</name>
+    <description>The AWS SDK for Java - module holds the classes for AWS Ion protocol
+    </description>
+    <url>https://aws.amazon.com/sdkforjava</url>
 
     <dependencies>
         <dependency>

protocols/aws-json-protocol/pom.xml

@@ -10,6 +10,10 @@
     <modelVersion>4.0.0</modelVersion>
 
     <artifactId>aws-json-protocol</artifactId>
+    <name>AWS Java SDK :: AWS Json Protocol</name>
+    <description>The AWS SDK for Java - module holds the classes for AWS Json protocol
+    </description>
+    <url>https://aws.amazon.com/sdkforjava</url>
 
     <dependencies>
         <dependency>

protocols/aws-query-protocol/pom.xml

@@ -10,6 +10,10 @@
     <modelVersion>4.0.0</modelVersion>
 
     <artifactId>aws-query-protocol</artifactId>
+    <name>AWS Java SDK :: AWS Query Protocol</name>
+    <description>The AWS SDK for Java - module holds the classes for AWS Query protocol
+    </description>
+    <url>https://aws.amazon.com/sdkforjava</url>
 
     <dependencies>
         <dependency>

protocols/protocol-core/pom.xml

@@ -10,6 +10,10 @@
     <modelVersion>4.0.0</modelVersion>
 
     <artifactId>protocol-core</artifactId>
+    <name>AWS Java SDK :: Protocol Core</name>
+    <description>The AWS SDK for Java - module holds the core protocol classes
+    </description>
+    <url>https://aws.amazon.com/sdkforjava</url>
 
 
     <dependencies>