Reusing ReadTimeoutHandler for 100continueExpected request

Author: zoewangg

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

@@ -169,12 +169,18 @@ private void writeRequest(HttpRequest request) {
                    // Done writing so remove the idle write timeout handler
                    ChannelUtils.removeIfExists(channel.pipeline(), WriteTimeoutHandler.class);
                    if (wireCall.isSuccess()) {
-                       if (!context.executeRequest().fullDuplex()) {
-                           // Starting read so add the idle read timeout handler, removed when channel is released
+                       if (context.executeRequest().fullDuplex()) {
+                           return;
+                       }
+
+                       // if it is 100ContinueExpected request, then we do not need to add another ReadTimeoutHandler
+                       if (!is100ContinueExpected()) {
                            channel.pipeline().addFirst(new ReadTimeoutHandler(context.configuration().readTimeoutMillis(),
                                                                               TimeUnit.MILLISECONDS));
-                           channel.read();
                        }
+
+                       channel.read();
+
                    } else {
                        // TODO: Are there cases where we can keep the channel open?
                        closeAndRelease(channel);
@@ -198,11 +204,15 @@ private void writeRequest(HttpRequest request) {
      * @return true if it should explicitly read from channel
      */
     private boolean shouldExplicitlyTriggerRead() {
-        boolean is100ContinueExpected = context.executeRequest().request()
-                                               .firstMatchingHeader("Expect")
-                                               .filter(b -> b.equalsIgnoreCase("100-continue")).isPresent();
+        return context.executeRequest().fullDuplex() || is100ContinueExpected();
+    }
 
-        return context.executeRequest().fullDuplex() || is100ContinueExpected;
+    private boolean is100ContinueExpected() {
+        return context.executeRequest()
+                      .request()
+                      .firstMatchingHeader("Expect")
+                      .filter(b -> b.equalsIgnoreCase("100-continue"))
+                      .isPresent();
     }
 
     private URI endpoint() {