idels feedback

Author: tkountis

servicetalk-http-netty/src/main/java/io/servicetalk/http/netty/DefaultHttpLoadBalancerFactory.java

@@ -134,6 +134,10 @@ public FilterableStreamingHttpLoadBalancedConnection toLoadBalancedConnection(
             }
         }
 
+        if (hostHealthIndicator == null) {
+            return HttpLoadBalancerFactory.super.toLoadBalancedConnection(connection, concurrencyController, context);
+        }
+
         return new DefaultHttpLoadBalancedConnection(connection, concurrencyController,
                 errorClassFunction, peerResponseErrorClassifier, hostHealthIndicator);
     }
@@ -357,11 +361,11 @@ public <T> Publisher<? extends T> transportEventStream(final HttpEventKey<T> eve
 
         @Override
         public Single<StreamingHttpResponse> request(final StreamingHttpRequest request) {
-            return Single.defer(() -> {
-                if (tracker == null) {
-                    return delegate.request(request).shareContextOnSubscribe();
-                }
+            if (tracker == null) {
+                return delegate.request(request).shareContextOnSubscribe();
+            }
 
+            return Single.defer(() -> {
                 final RequestTracker theTracker = new AtMostOnceDeliveryRequestTracker(tracker);
                 final long startTime = theTracker.beforeStart();
 
@@ -430,6 +434,11 @@ public StreamingHttpRequest newRequest(final HttpRequestMethod method, final Str
             return delegate.newRequest(method, requestTarget);
         }
 
+        @Override
+        public String toString() {
+            return delegate.toString();
+        }
+
         private static final class AtMostOnceDeliveryRequestTracker implements RequestTracker {
 
             private static final AtomicIntegerFieldUpdater<AtMostOnceDeliveryRequestTracker> doneUpdater =