KTOR-5099 Fix memory leak in HttpRequestRetry plugin (ktorio#3316)

Rattenkrieg · Jan 5, 2023 · c2f49e8 · c2f49e8
1 parent f2db562
commit c2f49e8
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/ktor-client/ktor-client-core/common/src/io/ktor/client/plugins/HttpRequestRetry.kt b/ktor-client/ktor-client-core/common/src/io/ktor/client/plugins/HttpRequestRetry.kt
@@ -327,8 +327,11 @@ public class HttpRequestRetry internal constructor(configuration: Configuration)
 
     private fun prepareRequest(request: HttpRequestBuilder): HttpRequestBuilder {
         val subRequest = HttpRequestBuilder().takeFrom(request)
-        val subRequestJob = Job(request.executionContext)
-        subRequest.executionContext = subRequestJob
+        request.executionContext.invokeOnCompletion { cause ->
+            val subRequestJob = subRequest.executionContext as CompletableJob
+            if (cause == null) subRequestJob.complete()
+            else subRequestJob.completeExceptionally(cause)
+        }
         return subRequest
     }