Package | Description |
---|---|
io.netty.bootstrap |
The helper classes with fluent API which enable an easy implementation of
typical client side and server side channel initialization.
|
io.netty.channel |
The core channel API which is asynchronous and event-driven abstraction of
various transports such as a
NIO Channel.
|
io.netty.channel.embedded |
A virtual
Channel that helps wrapping a series of handlers to
unit test the handlers or use them in non-I/O context. |
io.netty.channel.group |
A channel registry which helps a user maintain the list of open
Channel s and perform bulk operations on them. |
io.netty.channel.kqueue |
BSD specific transport.
|
io.netty.channel.local |
A virtual transport that enables the communication between the two
parties in the same virtual machine.
|
io.netty.channel.nio |
NIO-based channel
API implementation - recommended for a large number of connections (>= 1000).
|
io.netty.channel.oio |
Old blocking I/O based channel API implementation - recommended for
a small number of connections (< 1000).
|
io.netty.channel.pool |
Implementations and API for
Channel pools. |
io.netty.channel.sctp |
Abstract SCTP socket interfaces which extend the core channel API.
|
io.netty.channel.sctp.nio |
NIO-based SCTP Channel
API implementation - recommended for a large number of connections (>= 1000).
|
io.netty.channel.sctp.oio |
Old blocking I/O based SCTP channel API implementation - recommended for
a small number of connections (< 1000).
|
io.netty.channel.socket |
Abstract TCP and UDP socket interfaces which extend the core channel API.
|
io.netty.channel.socket.nio |
NIO-based socket channel
API implementation - recommended for a large number of connections (>= 1000).
|
io.netty.channel.socket.oio |
Old blocking I/O based socket channel API implementation - recommended for
a small number of connections (< 1000).
|
io.netty.channel.unix |
Unix specific transport.
|
io.netty.handler.ssl |
SSL ·
TLS implementation based on
SSLEngine |
io.netty.resolver.dns |
An alternative to Java's built-in domain name lookup mechanism that resolves a domain name asynchronously,
which supports the queries of an arbitrary DNS record type as well.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractBootstrap<B extends AbstractBootstrap<B,C>,C extends Channel>
AbstractBootstrap is a helper class that makes it easy to bootstrap a Channel . |
class |
AbstractBootstrapConfig<B extends AbstractBootstrap<B,C>,C extends Channel>
Exposes the configuration of an
AbstractBootstrap . |
interface |
ChannelFactory<T extends Channel>
Deprecated.
Use
ChannelFactory instead. |
Modifier and Type | Method and Description |
---|---|
private static void |
AbstractBootstrap.doBind0(ChannelFuture regFuture,
Channel channel,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
private ChannelFuture |
Bootstrap.doResolveAndConnect0(Channel channel,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
private static void |
ServerBootstrap.ServerBootstrapAcceptor.forceClose(Channel child,
java.lang.Throwable t) |
(package private) abstract void |
AbstractBootstrap.init(Channel channel) |
(package private) void |
Bootstrap.init(Channel channel) |
(package private) void |
ServerBootstrap.init(Channel channel) |
private static void |
AbstractBootstrap.setChannelOption(Channel channel,
ChannelOption<?> option,
java.lang.Object value,
InternalLogger logger) |
(package private) static void |
AbstractBootstrap.setChannelOptions(Channel channel,
java.util.Map.Entry<ChannelOption<?>,java.lang.Object>[] options,
InternalLogger logger) |
(package private) static void |
AbstractBootstrap.setChannelOptions(Channel channel,
java.util.Map<ChannelOption<?>,java.lang.Object> options,
InternalLogger logger) |
Constructor and Description |
---|
PendingRegistrationPromise(Channel channel) |
ServerBootstrapAcceptor(Channel channel,
EventLoopGroup childGroup,
ChannelHandler childHandler,
java.util.Map.Entry<ChannelOption<?>,java.lang.Object>[] childOptions,
java.util.Map.Entry<AttributeKey<?>,java.lang.Object>[] childAttrs) |
Modifier and Type | Interface and Description |
---|---|
interface |
ChannelFactory<T extends Channel>
Creates a new
Channel . |
class |
ChannelInitializer<C extends Channel>
A special
ChannelInboundHandler which offers an easy way to initialize a Channel once it was
registered to its EventLoop . |
class |
ReflectiveChannelFactory<T extends Channel>
A
ChannelFactory that instantiates a new Channel by invoking its default constructor reflectively. |
Modifier and Type | Interface and Description |
---|---|
interface |
ServerChannel
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractChannel
A skeletal
Channel implementation. |
class |
AbstractServerChannel
A skeletal server-side
Channel implementation. |
Modifier and Type | Field and Description |
---|---|
private Channel |
ThreadPerChannelEventLoop.ch |
private Channel |
ChannelOutboundBuffer.channel |
private Channel |
CoalescingBufferQueue.channel |
private Channel |
CompleteChannelFuture.channel |
protected Channel |
DefaultChannelConfig.channel |
private Channel |
DefaultChannelPipeline.channel |
private Channel |
DefaultChannelProgressivePromise.channel |
private Channel |
DefaultChannelPromise.channel |
private Channel |
VoidChannelPromise.channel |
private Channel |
AbstractChannel.parent |
Modifier and Type | Method and Description |
---|---|
Channel |
AbstractChannelHandlerContext.channel() |
Channel |
ChannelFuture.channel()
Returns a channel where the I/O operation associated with this
future takes place.
|
Channel |
ChannelHandlerContext.channel()
Return the
Channel which is bound to the ChannelHandlerContext . |
Channel |
ChannelPipeline.channel()
Returns the
Channel that this pipeline is attached to. |
Channel |
ChannelPromise.channel() |
Channel |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.channel() |
Channel |
CompleteChannelFuture.channel() |
Channel |
DefaultChannelPipeline.channel() |
Channel |
DefaultChannelProgressivePromise.channel() |
Channel |
DefaultChannelPromise.channel() |
Channel |
VoidChannelPromise.channel() |
Channel |
AbstractChannel.flush() |
Channel |
Channel.flush() |
Channel |
AbstractChannel.parent() |
Channel |
Channel.parent()
Returns the parent of this channel.
|
Channel |
AbstractChannel.read() |
Channel |
Channel.read() |
Modifier and Type | Method and Description |
---|---|
int |
AbstractChannel.compareTo(Channel o) |
ChannelFuture |
EventLoopGroup.register(Channel channel)
|
ChannelFuture |
MultithreadEventLoopGroup.register(Channel channel) |
ChannelFuture |
SingleThreadEventLoop.register(Channel channel) |
ChannelFuture |
ThreadPerChannelEventLoopGroup.register(Channel channel) |
ChannelFuture |
EventLoopGroup.register(Channel channel,
ChannelPromise promise)
Deprecated.
Use
EventLoopGroup.register(ChannelPromise) instead. |
ChannelFuture |
MultithreadEventLoopGroup.register(Channel channel,
ChannelPromise promise)
Deprecated.
|
ChannelFuture |
SingleThreadEventLoop.register(Channel channel,
ChannelPromise promise)
Deprecated.
|
ChannelFuture |
ThreadPerChannelEventLoop.register(Channel channel,
ChannelPromise promise)
Deprecated.
|
ChannelFuture |
ThreadPerChannelEventLoopGroup.register(Channel channel,
ChannelPromise promise)
Deprecated.
|
Constructor and Description |
---|
AbstractChannel(Channel parent)
Creates a new instance.
|
AbstractChannel(Channel parent,
ChannelId id)
Creates a new instance.
|
CoalescingBufferQueue(Channel channel) |
CoalescingBufferQueue(Channel channel,
int initSize) |
CompleteChannelFuture(Channel channel,
EventExecutor executor)
Creates a new instance.
|
DefaultChannelConfig(Channel channel) |
DefaultChannelConfig(Channel channel,
RecvByteBufAllocator allocator) |
DefaultChannelPipeline(Channel channel) |
DefaultChannelProgressivePromise(Channel channel)
Creates a new instance.
|
DefaultChannelProgressivePromise(Channel channel,
EventExecutor executor)
Creates a new instance.
|
DefaultChannelPromise(Channel channel)
Creates a new instance.
|
DefaultChannelPromise(Channel channel,
EventExecutor executor)
Creates a new instance.
|
FailedChannelFuture(Channel channel,
EventExecutor executor,
java.lang.Throwable cause)
Creates a new instance.
|
SucceededChannelFuture(Channel channel,
EventExecutor executor)
Creates a new instance.
|
VoidChannelPromise(Channel channel,
boolean fireException)
Creates a new instance.
|
Modifier and Type | Class and Description |
---|---|
class |
EmbeddedChannel
Base class for
Channel implementations that are used in an embedded fashion. |
Modifier and Type | Method and Description |
---|---|
ChannelFuture |
EmbeddedEventLoop.register(Channel channel) |
ChannelFuture |
EmbeddedEventLoop.register(Channel channel,
ChannelPromise promise)
Deprecated.
|
Modifier and Type | Field and Description |
---|---|
private Channel |
ChannelMatchers.InstanceMatcher.channel |
Modifier and Type | Field and Description |
---|---|
private java.lang.Class<? extends Channel> |
ChannelMatchers.ClassMatcher.clazz |
private java.util.Collection<java.util.Map.Entry<Channel,java.lang.Throwable>> |
ChannelGroupException.failed |
private java.util.Map<Channel,ChannelFuture> |
DefaultChannelGroupFuture.futures |
private java.util.concurrent.ConcurrentMap<ChannelId,Channel> |
DefaultChannelGroup.nonServerChannels |
private java.util.concurrent.ConcurrentMap<ChannelId,Channel> |
DefaultChannelGroup.serverChannels |
Modifier and Type | Method and Description |
---|---|
Channel |
ChannelGroup.find(ChannelId id)
|
Channel |
DefaultChannelGroup.find(ChannelId id) |
Modifier and Type | Method and Description |
---|---|
java.util.Iterator<java.util.Map.Entry<Channel,java.lang.Throwable>> |
ChannelGroupException.iterator()
Returns a
Iterator which contains all the Throwable that was a cause of the failure and the
related id of the Channel . |
java.util.Iterator<Channel> |
DefaultChannelGroup.iterator() |
Modifier and Type | Method and Description |
---|---|
boolean |
DefaultChannelGroup.add(Channel channel) |
ChannelFuture |
ChannelGroupFuture.find(Channel channel)
Returns the
ChannelFuture of the individual I/O operation which
is associated with the specified Channel . |
ChannelFuture |
DefaultChannelGroupFuture.find(Channel channel) |
ChannelFuture |
VoidChannelGroupFuture.find(Channel channel) |
static ChannelMatcher |
ChannelMatchers.is(Channel channel)
Returns a
ChannelMatcher that matches the given Channel . |
static ChannelMatcher |
ChannelMatchers.isNot(Channel channel)
Returns a
ChannelMatcher that matches all Channel s except the given. |
boolean |
ChannelMatcher.matches(Channel channel)
Returns
true if the operation should be also executed on the given Channel . |
boolean |
ChannelMatchers.CompositeMatcher.matches(Channel channel) |
boolean |
ChannelMatchers.InvertMatcher.matches(Channel channel) |
boolean |
ChannelMatchers.InstanceMatcher.matches(Channel ch) |
boolean |
ChannelMatchers.ClassMatcher.matches(Channel ch) |
Modifier and Type | Method and Description |
---|---|
static ChannelMatcher |
ChannelMatchers.isInstanceOf(java.lang.Class<? extends Channel> clazz)
Returns a
ChannelMatcher that matches all Channel s that are an instance of sub-type of
the given class. |
static ChannelMatcher |
ChannelMatchers.isNotInstanceOf(java.lang.Class<? extends Channel> clazz)
Returns a
ChannelMatcher that matches all Channel s that are not an
instance of sub-type of the given class. |
Constructor and Description |
---|
InstanceMatcher(Channel channel) |
Constructor and Description |
---|
ChannelGroupException(java.util.Collection<java.util.Map.Entry<Channel,java.lang.Throwable>> causes) |
ClassMatcher(java.lang.Class<? extends Channel> clazz) |
DefaultChannelGroupFuture(ChannelGroup group,
java.util.Map<Channel,ChannelFuture> futures,
EventExecutor executor) |
Modifier and Type | Class and Description |
---|---|
(package private) class |
AbstractKQueueChannel |
class |
AbstractKQueueServerChannel |
class |
AbstractKQueueStreamChannel |
class |
KQueueDatagramChannel |
class |
KQueueDomainSocketChannel |
class |
KQueueServerDomainSocketChannel |
class |
KQueueServerSocketChannel |
class |
KQueueSocketChannel |
Modifier and Type | Method and Description |
---|---|
(package private) abstract Channel |
AbstractKQueueServerChannel.newChildChannel(int fd,
byte[] remote,
int offset,
int len) |
protected Channel |
KQueueServerDomainSocketChannel.newChildChannel(int fd,
byte[] addr,
int offset,
int len) |
protected Channel |
KQueueServerSocketChannel.newChildChannel(int fd,
byte[] address,
int offset,
int len) |
Constructor and Description |
---|
AbstractKQueueChannel(Channel parent,
BsdSocket fd,
boolean active) |
AbstractKQueueChannel(Channel parent,
BsdSocket fd,
boolean active,
boolean writeFilterEnabled) |
AbstractKQueueStreamChannel(Channel parent,
BsdSocket fd,
boolean active) |
KQueueDomainSocketChannel(Channel parent,
BsdSocket fd) |
KQueueSocketChannel(Channel parent,
BsdSocket fd,
java.net.InetSocketAddress remote) |
Modifier and Type | Class and Description |
---|---|
class |
LocalChannel
A
Channel for the local transport. |
class |
LocalServerChannel
A
ServerChannel for the local transport which allows in VM communication. |
Modifier and Type | Field and Description |
---|---|
private static java.util.concurrent.ConcurrentMap<LocalAddress,Channel> |
LocalChannelRegistry.boundChannels |
Modifier and Type | Method and Description |
---|---|
(package private) static Channel |
LocalChannelRegistry.get(java.net.SocketAddress localAddress) |
Modifier and Type | Method and Description |
---|---|
(package private) static LocalAddress |
LocalChannelRegistry.register(Channel channel,
LocalAddress oldLocalAddress,
java.net.SocketAddress localAddress) |
Constructor and Description |
---|
LocalAddress(Channel channel)
Creates a new ephemeral port based on the ID of the specified channel.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractNioByteChannel
AbstractNioChannel base class for Channel s that operate on bytes. |
class |
AbstractNioChannel
Abstract base class for
Channel implementations which use a Selector based approach. |
class |
AbstractNioMessageChannel
AbstractNioChannel base class for Channel s that operate on messages. |
Constructor and Description |
---|
AbstractNioByteChannel(Channel parent,
java.nio.channels.SelectableChannel ch)
Create a new instance
|
AbstractNioChannel(Channel parent,
java.nio.channels.SelectableChannel ch,
int readInterestOp)
Create a new instance
|
AbstractNioMessageChannel(Channel parent,
java.nio.channels.SelectableChannel ch,
int readInterestOp) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractOioByteChannel
Abstract base class for OIO which reads and writes bytes from/to a Socket
|
class |
AbstractOioChannel
Abstract base class for
Channel implementations that use Old-Blocking-IO |
class |
AbstractOioMessageChannel
Abstract base class for OIO which reads and writes objects from/to a Socket
|
class |
OioByteStreamChannel
Abstract base class for OIO Channels that are based on streams.
|
Constructor and Description |
---|
AbstractOioByteChannel(Channel parent) |
AbstractOioChannel(Channel parent) |
AbstractOioMessageChannel(Channel parent) |
OioByteStreamChannel(Channel parent)
Create a new instance
|
Modifier and Type | Field and Description |
---|---|
private java.util.Deque<Channel> |
SimpleChannelPool.deque |
private Promise<Channel> |
FixedChannelPool.AcquireListener.originalPromise |
(package private) Promise<Channel> |
FixedChannelPool.AcquireTask.promise |
Modifier and Type | Method and Description |
---|---|
protected Channel |
SimpleChannelPool.pollChannel()
Poll a
Channel out of the internal storage to reuse it. |
Modifier and Type | Method and Description |
---|---|
Future<Channel> |
ChannelPool.acquire()
Acquire a
Channel from this ChannelPool . |
Future<Channel> |
SimpleChannelPool.acquire() |
Future<Channel> |
ChannelPool.acquire(Promise<Channel> promise)
Acquire a
Channel from this ChannelPool . |
Future<Channel> |
FixedChannelPool.acquire(Promise<Channel> promise) |
Future<Channel> |
SimpleChannelPool.acquire(Promise<Channel> promise) |
private Future<Channel> |
SimpleChannelPool.acquireHealthyFromPoolOrNew(Promise<Channel> promise)
Tries to retrieve healthy channel from the pool if any or creates a new channel otherwise.
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractChannelPoolHandler.channelAcquired(Channel ch)
NOOP implementation, sub-classes may override this.
|
void |
ChannelPoolHandler.channelAcquired(Channel ch)
Called once a
Channel was acquired by calling ChannelPool.acquire() or
ChannelPool.acquire(Promise) . |
void |
ChannelPoolHandler.channelCreated(Channel ch)
Called once a new
Channel is created in the ChannelPool . |
void |
AbstractChannelPoolHandler.channelReleased(Channel ch)
NOOP implementation, sub-classes may override this.
|
void |
ChannelPoolHandler.channelReleased(Channel ch)
Called once a
Channel was released by calling ChannelPool.release(Channel) or
ChannelPool.release(Channel, Promise) . |
private static void |
SimpleChannelPool.closeAndFail(Channel channel,
java.lang.Throwable cause,
Promise<?> promise) |
private static void |
SimpleChannelPool.closeChannel(Channel channel) |
private void |
SimpleChannelPool.doHealthCheck(Channel ch,
Promise<Channel> promise) |
private void |
SimpleChannelPool.doHealthCheckOnRelease(Channel channel,
Promise<java.lang.Void> promise) |
private void |
SimpleChannelPool.doReleaseChannel(Channel channel,
Promise<java.lang.Void> promise) |
Future<java.lang.Boolean> |
ChannelHealthChecker.isHealthy(Channel channel)
Check if the given channel is healthy which means it can be used.
|
private void |
SimpleChannelPool.notifyHealthCheck(Future<java.lang.Boolean> future,
Channel ch,
Promise<Channel> promise) |
protected boolean |
SimpleChannelPool.offerChannel(Channel channel)
Offer a
Channel back to the internal storage. |
Future<java.lang.Void> |
ChannelPool.release(Channel channel)
Release a
Channel back to this ChannelPool . |
Future<java.lang.Void> |
SimpleChannelPool.release(Channel channel) |
Future<java.lang.Void> |
ChannelPool.release(Channel channel,
Promise<java.lang.Void> promise)
Release a
Channel back to this ChannelPool . |
Future<java.lang.Void> |
FixedChannelPool.release(Channel channel,
Promise<java.lang.Void> promise) |
Future<java.lang.Void> |
SimpleChannelPool.release(Channel channel,
Promise<java.lang.Void> promise) |
private void |
SimpleChannelPool.releaseAndOffer(Channel channel,
Promise<java.lang.Void> promise) |
private void |
SimpleChannelPool.releaseAndOfferIfHealthy(Channel channel,
Promise<java.lang.Void> promise,
Future<java.lang.Boolean> future)
Adds the channel back to the pool only if the channel is healthy.
|
Modifier and Type | Method and Description |
---|---|
Future<Channel> |
ChannelPool.acquire(Promise<Channel> promise)
Acquire a
Channel from this ChannelPool . |
Future<Channel> |
FixedChannelPool.acquire(Promise<Channel> promise) |
Future<Channel> |
SimpleChannelPool.acquire(Promise<Channel> promise) |
private void |
FixedChannelPool.acquire0(Promise<Channel> promise) |
private Future<Channel> |
SimpleChannelPool.acquireHealthyFromPoolOrNew(Promise<Channel> promise)
Tries to retrieve healthy channel from the pool if any or creates a new channel otherwise.
|
private void |
SimpleChannelPool.doHealthCheck(Channel ch,
Promise<Channel> promise) |
private void |
SimpleChannelPool.notifyConnect(ChannelFuture future,
Promise<Channel> promise) |
private void |
SimpleChannelPool.notifyHealthCheck(Future<java.lang.Boolean> future,
Channel ch,
Promise<Channel> promise) |
void |
FixedChannelPool.AcquireListener.operationComplete(Future<Channel> future) |
Constructor and Description |
---|
AcquireListener(Promise<Channel> originalPromise) |
AcquireTask(Promise<Channel> promise) |
Modifier and Type | Interface and Description |
---|---|
interface |
SctpChannel
A SCTP/IP
Channel interface for single SCTP association. |
interface |
SctpServerChannel
A SCTP/IP
ServerChannel which accepts incoming SCTP/IP associations. |
Modifier and Type | Class and Description |
---|---|
class |
NioSctpChannel
SctpChannel implementation which use non-blocking mode and allows to read /
write SctpMessage s to the underlying SctpChannel . |
class |
NioSctpServerChannel
SctpServerChannel implementation which use non-blocking mode to accept new
connections and create the NioSctpChannel for them. |
Constructor and Description |
---|
NioSctpChannel(Channel parent,
SctpChannel sctpChannel)
Create a new instance
|
Modifier and Type | Class and Description |
---|---|
class |
OioSctpChannel
SctpChannel implementation which use blocking mode and allows to read / write
SctpMessage s to the underlying SctpChannel . |
class |
OioSctpServerChannel
SctpServerChannel implementation which use blocking mode to accept new
connections and create the OioSctpChannel for them. |
Constructor and Description |
---|
OioSctpChannel(Channel parent,
SctpChannel ch)
Create a new instance from the given
SctpChannel . |
Modifier and Type | Interface and Description |
---|---|
interface |
DatagramChannel
A UDP/IP
Channel . |
interface |
DuplexChannel
A duplex
Channel that has two sides that can be shutdown independently. |
interface |
ServerSocketChannel
A TCP/IP
ServerChannel which accepts incoming TCP/IP connections. |
interface |
SocketChannel
A TCP/IP socket
Channel . |
Modifier and Type | Class and Description |
---|---|
class |
NioDatagramChannel
An NIO datagram
Channel that sends and receives an
AddressedEnvelope . |
class |
NioServerSocketChannel
A
ServerSocketChannel implementation which uses
NIO selector based implementation to accept new connections. |
class |
NioSocketChannel
SocketChannel which uses NIO selector based implementation. |
Constructor and Description |
---|
NioSocketChannel(Channel parent,
java.nio.channels.SocketChannel socket)
Create a new instance
|
Modifier and Type | Class and Description |
---|---|
class |
OioDatagramChannel
An OIO datagram
Channel that sends and receives an
AddressedEnvelope . |
class |
OioServerSocketChannel
ServerSocketChannel which accepts new connections and create the OioSocketChannel 's for them. |
class |
OioSocketChannel
A
SocketChannel which is using Old-Blocking-IO |
Constructor and Description |
---|
OioSocketChannel(Channel parent,
java.net.Socket socket)
Create a new instance from the given
Socket |
Modifier and Type | Interface and Description |
---|---|
interface |
DomainSocketChannel
A
UnixChannel that supports communication via
Unix Domain Socket. |
interface |
ServerDomainSocketChannel
|
interface |
UnixChannel
Channel that expose operations that are only present on UNIX like systems. |
Modifier and Type | Field and Description |
---|---|
private Promise<Channel> |
SslHandler.handshakePromise |
Modifier and Type | Method and Description |
---|---|
Future<Channel> |
SslHandler.handshakeFuture()
Returns a
Future that will get notified once the current TLS handshake completes. |
Future<Channel> |
SslHandler.renegotiate()
Performs TLS renegotiation.
|
Future<Channel> |
SslHandler.renegotiate(Promise<Channel> promise)
Performs TLS renegotiation.
|
Future<Channel> |
SslHandler.sslCloseFuture()
Return the
Future that will get notified if the inbound of the SSLEngine is closed. |
Modifier and Type | Method and Description |
---|---|
private void |
SslHandler.handshake(Promise<Channel> newHandshakePromise)
Performs TLS (re)negotiation.
|
Future<Channel> |
SslHandler.renegotiate(Promise<Channel> promise)
Performs TLS renegotiation.
|
Modifier and Type | Field and Description |
---|---|
private Promise<Channel> |
DnsNameResolver.DnsResponseHandler.channelActivePromise |
(package private) Future<Channel> |
DnsNameResolver.channelFuture |
Constructor and Description |
---|
DnsResponseHandler(Promise<Channel> channelActivePromise) |