Package | Description |
---|---|
io.netty.channel |
The core channel API which is asynchronous and event-driven abstraction of
various transports such as a
NIO Channel.
|
io.netty.handler.ssl | |
io.netty.resolver |
Resolves an arbitrary string that represents the name of an endpoint into a
SocketAddress . |
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.
|
io.netty.util.concurrent |
Utility classes for concurrent / async tasks.
|
Modifier and Type | Interface and Description |
---|---|
interface |
ChannelProgressivePromise
Special
ChannelPromise which will be notified once the associated bytes is transferring. |
interface |
ChannelPromise
Special
ChannelFuture which is writable. |
Modifier and Type | Class and Description |
---|---|
class |
DefaultChannelProgressivePromise
The default
ChannelProgressivePromise implementation. |
class |
DefaultChannelPromise
The default
ChannelPromise implementation. |
Modifier and Type | Method and Description |
---|---|
Future<Channel> |
SslHandler.renegotiate(Promise<Channel> promise)
Performs TLS renegotiation.
|
Modifier and Type | Method and Description |
---|---|
protected void |
DefaultNameResolver.doResolve(InetSocketAddress unresolvedAddress,
Promise<InetSocketAddress> promise) |
protected void |
NoopNameResolver.doResolve(SocketAddress unresolvedAddress,
Promise<SocketAddress> promise) |
protected abstract void |
SimpleNameResolver.doResolve(T unresolvedAddress,
Promise<T> promise)
Invoked by
SimpleNameResolver.resolve(SocketAddress) and SimpleNameResolver.resolve(String, int) to perform the actual name
resolution. |
Future<T> |
NameResolver.resolve(SocketAddress address,
Promise<T> promise)
Resolves the specified address.
|
Future<T> |
SimpleNameResolver.resolve(SocketAddress address,
Promise<T> promise) |
Future<T> |
NameResolver.resolve(String inetHost,
int inetPort,
Promise<T> promise)
Resolves the specified name into a
SocketAddress . |
Future<T> |
SimpleNameResolver.resolve(String inetHost,
int inetPort,
Promise<T> promise) |
Modifier and Type | Method and Description |
---|---|
protected void |
DnsNameResolver.doResolve(InetSocketAddress unresolvedAddress,
Promise<InetSocketAddress> promise) |
Future<DnsResponse> |
DnsNameResolver.query(DnsQuestion question,
Promise<DnsResponse> promise)
Sends a DNS query with the specified question.
|
Future<DnsResponse> |
DnsNameResolver.query(Iterable<InetSocketAddress> nameServerAddresses,
DnsQuestion question,
Promise<DnsResponse> promise)
Sends a DNS query with the specified question using the specified name server list.
|
Modifier and Type | Interface and Description |
---|---|
interface |
ProgressivePromise<V>
Special
ProgressiveFuture which is writable. |
Modifier and Type | Class and Description |
---|---|
class |
DefaultProgressivePromise<V> |
class |
DefaultPromise<V> |
Modifier and Type | Method and Description |
---|---|
Promise<V> |
Promise.addListener(GenericFutureListener<? extends Future<? super V>> listener) |
Promise<V> |
DefaultPromise.addListener(GenericFutureListener<? extends Future<? super V>> listener) |
Promise<V> |
Promise.addListeners(GenericFutureListener<? extends Future<? super V>>... listeners) |
Promise<V> |
DefaultPromise.addListeners(GenericFutureListener<? extends Future<? super V>>... listeners) |
Promise<V> |
Promise.await() |
Promise<V> |
DefaultPromise.await() |
Promise<V> |
Promise.awaitUninterruptibly() |
Promise<V> |
DefaultPromise.awaitUninterruptibly() |
<V> Promise<V> |
EventExecutor.newPromise()
Return a new
Promise . |
<V> Promise<V> |
ImmediateEventExecutor.newPromise() |
<V> Promise<V> |
AbstractEventExecutor.newPromise() |
Promise<V> |
Promise.removeListener(GenericFutureListener<? extends Future<? super V>> listener) |
Promise<V> |
DefaultPromise.removeListener(GenericFutureListener<? extends Future<? super V>> listener) |
Promise<V> |
Promise.removeListeners(GenericFutureListener<? extends Future<? super V>>... listeners) |
Promise<V> |
DefaultPromise.removeListeners(GenericFutureListener<? extends Future<? super V>>... listeners) |
Promise<V> |
Promise.setFailure(Throwable cause)
Marks this future as a failure and notifies all
listeners.
|
Promise<V> |
DefaultPromise.setFailure(Throwable cause) |
Promise<V> |
Promise.setSuccess(V result)
Marks this future as a success and notifies all
listeners.
|
Promise<V> |
DefaultPromise.setSuccess(V result) |
Promise<V> |
Promise.sync() |
Promise<V> |
DefaultPromise.sync() |
Promise<V> |
Promise.syncUninterruptibly() |
Promise<V> |
DefaultPromise.syncUninterruptibly() |
Modifier and Type | Method and Description |
---|---|
PromiseAggregator<V,F> |
PromiseAggregator.add(Promise<V>... promises)
Add the given
Promise s to the aggregator. |
Constructor and Description |
---|
PromiseAggregator(Promise<Void> aggregatePromise)
|
PromiseAggregator(Promise<Void> aggregatePromise,
boolean failPending)
Creates a new instance.
|
PromiseNotifier(Promise<? super V>... promises)
Create a new instance.
|
Copyright © 2008–2015 The Netty Project. All rights reserved.