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

Class SdkChannelPoolMap<K,P extends io.netty.channel.pool.ChannelPool>

java.lang.Object

software.amazon.awssdk.http.nio.netty.internal.SdkChannelPoolMap<K,P>

All Implemented Interfaces:

io.netty.channel.pool.ChannelPoolMap<K,P>, Closeable, AutoCloseable, Iterable<Map.Entry<K,P>>

Direct Known Subclasses:

AwaitCloseChannelPoolMap

public abstract class SdkChannelPoolMap<K,P extends io.netty.channel.pool.ChannelPool>
extends Object
implements io.netty.channel.pool.ChannelPoolMap<K,P>, Iterable<Map.Entry<K,P>>, Closeable

Replacement for AbstractChannelPoolMap. This implementation guarantees only one instance of a ChannelPool is created for each key.

Constructor Summary

Constructors

Constructor and Description
SdkChannelPoolMap()

Method Summary

Modifier and Type	Method and Description
void	close()
boolean	contains(K key)
P	get(K key)
boolean	isEmpty() Returns true if the AbstractChannelPoolMap is empty, otherwise false.
Iterator<Map.Entry<K,P>>	iterator()
protected abstract P	newPool(K key) Called once a new ChannelPool needs to be created as non exists yet for the key.
Map<K,P>	pools()
boolean	remove(K key) Remove the ChannelPool from this AbstractChannelPoolMap.
int	size() Returns the number of ChannelPools currently in this AbstractChannelPoolMap.

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

SdkChannelPoolMap

public SdkChannelPoolMap()

Method Detail

get

public final P get(K key)

Specified by:

get in interface io.netty.channel.pool.ChannelPoolMap<K,P extends io.netty.channel.pool.ChannelPool>

remove

public final boolean remove(K key)

Remove the ChannelPool from this AbstractChannelPoolMap. Returns true if removed, false otherwise. Please note that null keys are not allowed.

iterator

public final Iterator<Map.Entry<K,P>> iterator()

Specified by:

iterator in interface Iterable<Map.Entry<K,P extends io.netty.channel.pool.ChannelPool>>

size

public final int size()

Returns the number of ChannelPools currently in this AbstractChannelPoolMap.

isEmpty

public final boolean isEmpty()

Returns true if the AbstractChannelPoolMap is empty, otherwise false.

contains

public final boolean contains(K key)

Specified by:

contains in interface io.netty.channel.pool.ChannelPoolMap<K,P extends io.netty.channel.pool.ChannelPool>

newPool

protected abstract P newPool(K key)

Called once a new ChannelPool needs to be created as non exists yet for the key.

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

pools

public final Map<K,P> pools()