From 0906ba2f3266e7bd2319e3896ee71ef1cb4b8d58 Mon Sep 17 00:00:00 2001
From: Lauri Tulmin <ltulmin@splunk.com>
Date: Tue, 16 Nov 2021 02:09:02 +0200
Subject: [PATCH] Fix memory leak when using ktor-client-java (#4637)

---
 .../instrumentation/httpclient/BodyHandlerWrapper.java          | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/instrumentation/java-http-client/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/httpclient/BodyHandlerWrapper.java b/instrumentation/java-http-client/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/httpclient/BodyHandlerWrapper.java
index 9249f2846d3c..e3380f5e85a3 100644
--- a/instrumentation/java-http-client/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/httpclient/BodyHandlerWrapper.java
+++ b/instrumentation/java-http-client/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/httpclient/BodyHandlerWrapper.java
@@ -30,7 +30,7 @@ public BodySubscriber<T> apply(ResponseInfo responseInfo) {
     if (subscriber instanceof BodySubscriberWrapper) {
       return subscriber;
     }
-    return new BodySubscriberWrapper<>(delegate.apply(responseInfo), context);
+    return new BodySubscriberWrapper<>(subscriber, context);
   }
 
   public static class BodySubscriberWrapper<T> implements BodySubscriber<T> {