spring/spring-framework
1
0
Fork 0
mirror of https://github.com/spring-projects/spring-framework.git synced 2026-09-17 16:39:29 +00:00
Code Issues Projects Releases Wiki Activity

Polishing in ReactorClientHttpConnector

Browse Source
This commit is contained in:
rstoyanchev
2026-01-26 10:51:00 +00:00
parent e809395635
commit 77c24b28b6
1 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
spring-web/src/main/java/org/springframework/http/client/reactive/ReactorClientHttpConnector.java
+5 -4
View File
@@ -168,7 +168,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()
@@ -198,12 +198,13 @@ 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) {
// Deprecation note on remove method: consider using set(Object) (with value of null)
connection.channel().attr(ATTRIBUTES_KEY).set(null);
}