From 7b7126ae3dbe22d5414c95f4f953f65b78744f4e Mon Sep 17 00:00:00 2001 From: rstoyanchev Date: Mon, 26 Jan 2026 10:46:59 +0000 Subject: [PATCH] Polishing in ReactorClientHttpConnector --- .../http/client/reactive/ReactorClientHttpConnector.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/spring-web/src/main/java/org/springframework/http/client/reactive/ReactorClientHttpConnector.java b/spring-web/src/main/java/org/springframework/http/client/reactive/ReactorClientHttpConnector.java index ae7adb59355..6a29b244c43 100644 --- a/spring-web/src/main/java/org/springframework/http/client/reactive/ReactorClientHttpConnector.java +++ b/spring-web/src/main/java/org/springframework/http/client/reactive/ReactorClientHttpConnector.java @@ -171,7 +171,7 @@ public class ReactorClientHttpConnector implements ClientHttpConnector, SmartLif .responseConnection((response, connection) -> { ReactorClientHttpResponse clientResponse = new ReactorClientHttpResponse(response, connection); responseRef.set(clientResponse); - clearChannelAttribute(connection); + registerAttributeCallback(connection); return Mono.just((ClientHttpResponse) clientResponse); }) .next() @@ -201,9 +201,9 @@ public class ReactorClientHttpConnector implements ClientHttpConnector, SmartLif return new ReactorClientHttpRequest(method, uri, request, nettyOutbound); } - private static void clearChannelAttribute(Connection connection) { - connection.onTerminate().subscribe( - aVoid -> {}, ex -> clearAttribute(connection), () -> clearAttribute(connection)); + private static void registerAttributeCallback(Connection connection) { + connection.onTerminate().subscribe(aVoid -> {}, + ex -> clearAttribute(connection), () -> clearAttribute(connection)); } private static void clearAttribute(Connection connection) {