diff --git a/spring-web/src/main/java/org/springframework/http/client/reactive/HttpComponentsClientHttpConnector.java b/spring-web/src/main/java/org/springframework/http/client/reactive/HttpComponentsClientHttpConnector.java
index 90ed8ff36b2..612da6ec348 100644
--- a/spring-web/src/main/java/org/springframework/http/client/reactive/HttpComponentsClientHttpConnector.java
+++ b/spring-web/src/main/java/org/springframework/http/client/reactive/HttpComponentsClientHttpConnector.java
@@ -16,6 +16,8 @@
package org.springframework.http.client.reactive;
+import java.io.Closeable;
+import java.io.IOException;
import java.net.URI;
import java.nio.ByteBuffer;
import java.util.function.BiFunction;
@@ -48,7 +50,7 @@ import org.springframework.util.Assert;
* @since 5.3
* @see Apache HttpComponents
*/
-public class HttpComponentsClientHttpConnector implements ClientHttpConnector {
+public class HttpComponentsClientHttpConnector implements ClientHttpConnector, Closeable {
private final CloseableHttpAsyncClient client;
@@ -126,6 +128,10 @@ public class HttpComponentsClientHttpConnector implements ClientHttpConnector {
});
}
+ @Override
+ public void close() throws IOException {
+ this.client.close();
+ }
private static class MonoFutureCallbackAdapter
implements FutureCallback>> {