Close stream on completion

Author: lauzadis

runtime/protocol/http-client-engines/http-client-engine-crt/jvm/src/aws/smithy/kotlin/runtime/http/engine/crt/CrtHttpEngine.kt

@@ -64,11 +64,6 @@ public class CrtHttpEngine(public override val config: CrtHttpEngineConfig) : Ht
         logger.trace { "Acquired connection ${conn.id}" }
 
         val respHandler = SdkStreamResponseHandler(conn, callContext)
-        callContext.job.invokeOnCompletion {
-            logger.trace { "completing handler; cause=$it" }
-            // ensures the stream is driven to completion regardless of what the downstream consumer does
-            respHandler.complete()
-        }
 
         val reqTime = Instant.now()
         val engineRequest = request.toCrtRequest(callContext)
@@ -79,6 +74,12 @@ public class CrtHttpEngine(public override val config: CrtHttpEngineConfig) : Ht
             }
         }
 
+        callContext.job.invokeOnCompletion {
+            // ensures the stream is driven to completion regardless of what the downstream consumer does
+            stream.close()
+            respHandler.complete()
+        }
+
         if (request.isChunked) {
             withContext(SdkDispatchers.IO) {
                 stream.sendChunkedBody(request.body)