Fix memory leak when using ktor-client-java (open-telemetry#4637)

RashmiRam · May 23, 2022 · 0906ba2 · 0906ba2
1 parent 773feb4
commit 0906ba2
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...c/main/java/io/opentelemetry/javaagent/instrumentation/httpclient/BodyHandlerWrapper.java b/...c/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> {