如何在使用reactor tcpclient时释放池连接

import reactor.core.publisher.Mono;
import reactor.netty.tcp.TcpClient;
import reactor.netty.resources.ConnectionProvider;
import reactor.netty.resources.PooledConnectionProvider;
import reactor.netty.resources.PoolResources;

// 创建连接池
ConnectionProvider connectionProvider = ConnectionProvider.builder("connectionPool")
        .maxConnections(10)
        .pendingAcquireMaxCount(50)
        .pendingAcquireTimeout(Duration.ofSeconds(30))
        .maxIdleTime(Duration.ofMinutes(10))
        .maxLifeTime(Duration.ofMinutes(30))
        .build();

PoolResources poolResources = PoolResources.builder()
        .connectionProvider(connectionProvider)
        .build();

PooledConnectionProvider pooledConnectionProvider = PooledConnectionProvider.create(poolResources);

// 创建TcpClient并获取连接对象
TcpClient tcpClient = TcpClient.create()
        .port(8080)
        .host("localhost")
        .handle((in, out) -> {
            // 对连接对象进行操作，发送请求或接收响应
            // ...
            // 释放连接对象
            return out.sendString(Mono.just("Hello"))
                    .then(in.receive().asString())
                    .doFinally(signalType -> pooledConnectionProvider.disposeWhen(poolResources, pooledConnectionProvider.metrics().acquiredSize() == 0));
        });

// 使用TcpClient连接对象进行操作
tcpClient.connect()
        .flatMapMany(conn -> conn.outbound().sendString(Mono.just("Hello")))
        .thenMany(client -> client.inbound().receive().asString())
        .doFinally(signalType -> pooledConnectionProvider.disposeWhen(poolResources, pooledConnectionProvider.metrics().acquiredSize() == 0))
        .blockLast();

// 关闭连接池
pooledConnectionProvider.dispose();