Merge pull request #4 from vikasojha0536/patch-1

Update ResponseFilter.java
telekom · Nov 29, 2024 · 6519832 · 6519832
2 parents 23693b7 + ecc8f85
commit 6519832
Showing 1 changed file with 6 additions and 4 deletions.
diff --git a/src/main/java/jumper/filter/ResponseFilter.java b/src/main/java/jumper/filter/ResponseFilter.java
@@ -45,9 +45,10 @@ public GatewayFilter apply(Config config) {
         (exchange, chain) ->
             chain
                 .filter(exchange)
-                .then(
-                    Mono.fromRunnable(
-                        () ->
+                .doOnTerminate(() -> {
+                        if (exchange.getResponse().isCommitted()) {
+                            return;
+                        }
                             WebFluxSleuthOperators.withSpanInScope(
                                 tracer,
                                 currentTraceContext,
@@ -90,7 +91,8 @@ public GatewayFilter apply(Config config) {
                                   }
 
                                   span.event("jrpf");
-                                }))),
+                                });
+                }),
         RequestFilter.REQUEST_FILTER_ORDER);
   }