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

Class CancellableAcquireChannelPool

java.lang.Object

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

All Implemented Interfaces:

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

public final class CancellableAcquireChannelPool
extends Object
implements io.netty.channel.pool.ChannelPool

Simple decorator ChannelPool that attempts to complete the promise given to acquire(Promise) with the channel acquired from the underlying pool. If it fails (because the promise is already done), the acquired channel is closed then released back to the delegate.

Constructor Summary

Constructors

Constructor and Description
CancellableAcquireChannelPool(io.netty.util.concurrent.EventExecutor executor, io.netty.channel.pool.ChannelPool delegatePool)

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> acquirePromise)
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

Constructor Detail

CancellableAcquireChannelPool

public CancellableAcquireChannelPool(io.netty.util.concurrent.EventExecutor executor,
                                     io.netty.channel.pool.ChannelPool delegatePool)

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> acquirePromise)

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