From b7faca0d07a904862412627766df04ae9c98ca19 Mon Sep 17 00:00:00 2001 From: "Sean C. Sullivan" Date: Fri, 27 Oct 2023 14:51:03 -0700 Subject: [PATCH] LoadBalancerCommand.java --- .../com/netflix/loadbalancer/reactive/LoadBalancerCommand.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/ribbon-loadbalancer/src/main/java/com/netflix/loadbalancer/reactive/LoadBalancerCommand.java b/ribbon-loadbalancer/src/main/java/com/netflix/loadbalancer/reactive/LoadBalancerCommand.java index 2c434cf6..2db9db56 100644 --- a/ribbon-loadbalancer/src/main/java/com/netflix/loadbalancer/reactive/LoadBalancerCommand.java +++ b/ribbon-loadbalancer/src/main/java/com/netflix/loadbalancer/reactive/LoadBalancerCommand.java @@ -41,7 +41,6 @@ import com.netflix.loadbalancer.Server; import com.netflix.loadbalancer.ServerStats; import com.netflix.loadbalancer.reactive.ExecutionListener.AbortExecutionException; -import com.netflix.servo.monitor.Stopwatch; /** * A command that is used to produce the Observable from the load balancer execution. The load balancer is responsible for @@ -299,7 +298,7 @@ public Observable call(final Server server) { } final Stopwatch tracer = loadBalancerContext.getExecuteTracer().start(); - + return operation.call(server).doOnEach(new Observer() { private T entity; @Override