software.amazon.awssdk.http.nio.netty.internal.utils

Class BetterFixedChannelPool

java.lang.Object

software.amazon.awssdk.http.nio.netty.internal.utils.BetterFixedChannelPool

All Implemented Interfaces:

io.netty.channel.pool.ChannelPool, Closeable, AutoCloseable

public class BetterFixedChannelPool
extends Object
implements io.netty.channel.pool.ChannelPool

ChannelPool implementation that takes another ChannelPool implementation and enforce a maximum number of concurrent connections.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	BetterFixedChannelPool.AcquireTimeoutAction
static class	BetterFixedChannelPool.Builder

Method Summary

Modifier and Type	Method and Description
io.netty.util.concurrent.Future<io.netty.channel.Channel>	acquire()
io.netty.util.concurrent.Future<io.netty.channel.Channel>	acquire(io.netty.util.concurrent.Promise<io.netty.channel.Channel> promise)
static BetterFixedChannelPool.Builder	builder()
void	close()
io.netty.util.concurrent.Future<Void>	release(io.netty.channel.Channel channel)
io.netty.util.concurrent.Future<Void>	release(io.netty.channel.Channel channel, io.netty.util.concurrent.Promise<Void> promise)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

acquire

public io.netty.util.concurrent.Future<io.netty.channel.Channel> acquire()

Specified by:

acquire in interface io.netty.channel.pool.ChannelPool

acquire

public io.netty.util.concurrent.Future<io.netty.channel.Channel> acquire(io.netty.util.concurrent.Promise<io.netty.channel.Channel> promise)

Specified by:

acquire in interface io.netty.channel.pool.ChannelPool

release

public io.netty.util.concurrent.Future<Void> release(io.netty.channel.Channel channel)

Specified by:

release in interface io.netty.channel.pool.ChannelPool

release

public io.netty.util.concurrent.Future<Void> release(io.netty.channel.Channel channel,
                                                     io.netty.util.concurrent.Promise<Void> promise)

Specified by:

release in interface io.netty.channel.pool.ChannelPool

close

public void close()

Specified by:

close in interface io.netty.channel.pool.ChannelPool

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

builder

public static BetterFixedChannelPool.Builder builder()