下面列出了io.netty.channel.pool.FixedChannelPool#io.netty.channel.pool.ChannelPoolHandler 实例代码,或者点击链接到github查看源代码,也可以在右侧发表评论。
@SdkTestInternalApi
Http1TunnelConnectionPool(EventLoop eventLoop, ChannelPool delegate, SslContext sslContext,
URI proxyAddress, URI remoteAddress, ChannelPoolHandler handler,
InitHandlerSupplier initHandlerSupplier) {
this.eventLoop = eventLoop;
this.delegate = delegate;
this.sslContext = sslContext;
this.proxyAddress = proxyAddress;
this.remoteAddress = remoteAddress;
this.handler = handler;
this.initHandlerSupplier = initHandlerSupplier;
}
BetterSimpleChannelPool(Bootstrap bootstrap, ChannelPoolHandler handler) {
super(bootstrap, handler);
closeFuture = new CompletableFuture<>();
}
public Http1TunnelConnectionPool(EventLoop eventLoop, ChannelPool delegate, SslContext sslContext,
URI proxyAddress, URI remoteAddress, ChannelPoolHandler handler) {
this(eventLoop, delegate, sslContext, proxyAddress, remoteAddress, handler, ProxyTunnelInitHandler::new);
}
public ConnectionlessChannelPool(Bootstrap bootstrap, ChannelPoolHandler handler) {
super(bootstrap, handler);
}
public ConnectionlessChannelPool(Bootstrap bootstrap, ChannelPoolHandler handler, ChannelHealthChecker healthCheck) {
super(bootstrap, handler, healthCheck);
}
public ConnectionlessChannelPool(Bootstrap bootstrap, ChannelPoolHandler handler, ChannelHealthChecker healthCheck, boolean releaseHealthCheck) {
super(bootstrap, handler, healthCheck, releaseHealthCheck);
}
/**
* @return The {@link ChannelPoolHandler}
*/
public ChannelPoolHandler getChannelPoolHandler() {
return channelPoolHandler;
}