rename

Author: samwright

instrumentation/pekko/pekko-http-1.0/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/pekkohttp/v1_0/server/GraphInterpreterInstrumentation.java

@@ -35,7 +35,7 @@ public static class PushAdvice {
     public static Scope onEnter(@Advice.Argument(0) GraphInterpreter.Connection connection) {
       // processPush is called when execution passes to application or server. Here we propagate the
       // context to the application code.
-      Context context = PekkoFlowWrapper.getContext(connection.outHandler());
+      Context context = PekkoFlowWrapper.getAndRemoveContext(connection.outHandler());
       if (context != null) {
         return context.makeCurrent();
       }

instrumentation/pekko/pekko-http-1.0/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/pekkohttp/v1_0/server/PekkoFlowWrapper.java

@@ -36,12 +36,10 @@ public class PekkoFlowWrapper
     return handler.join(new PekkoFlowWrapper());
   }
 
-  public static Context getContext(OutHandler outHandler) {
+  public static Context getAndRemoveContext(OutHandler outHandler) {
     if (outHandler instanceof TracingLogic.ApplicationOutHandler) {
       // We have multiple requests here only when requests are pipelined on the same connection.
-      // It appears that these requests are processed one by one so processing next request won't
-      // be started before the first one has returned a response, because of this the first request
-      // in the queue is always the one that is currently being processed.
+      // We remove the context off of the queue so that the next request can get its context.
       PekkoTracingRequest request =
           ((TracingLogic.ApplicationOutHandler) outHandler).getRequests().poll();
       if (request != null) {