Intermittent test failure with keep-alive enabled fixed (#2238)

Signed-off-by: David Kral <david.k.kral@oracle.com>
helidon-io · Aug 7, 2020 · b5606e7 · b5606e7
1 parent 96421c7
commit b5606e7
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/webclient/webclient/src/main/java/io/helidon/webclient/NettyClientHandler.java b/webclient/webclient/src/main/java/io/helidon/webclient/NettyClientHandler.java
@@ -290,15 +290,14 @@ Single<Void> close() {
                 WebClientServiceResponse clientServiceResponse = channel.attr(SERVICE_RESPONSE).get();
                 CompletableFuture<WebClientServiceResponse> requestComplete = channel.attr(COMPLETED).get();
                 requestComplete.complete(clientServiceResponse);
-                channel.config().setAutoRead(true);
                 WebClientResponse response = channel.attr(RESPONSE).get();
                 String connection = response.headers().first(Http.Header.CONNECTION)
                         .orElseGet(HttpHeaderValues.CLOSE::toString);
                 if (connection.equals(HttpHeaderValues.CLOSE.toString())) {
                     ctx.close()
                             .addListener(future -> {
                                 if (future.isSuccess()) {
-                                    LOGGER.finest(() -> "Response from has been closed.");
+                                    LOGGER.finest(() -> "Response from the server has been closed.");
                                     cf.complete(null);
                                 } else {
                                     LOGGER.log(Level.SEVERE,
@@ -310,6 +309,7 @@ Single<Void> close() {
                 } else {
                     channel.attr(IN_USE).get().set(false);
                     cf.complete(null);
+                    channel.read();
                 }
                 publisher.complete();
             }