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.channel.group |
A channel registry which helps a user maintain the list of open
Channel s and perform bulk operations on them. |
io.netty.handler.proxy |
Adds support for client connections via proxy protocols such as
SOCKS and
HTTP CONNECT tunneling
|
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 |
ChannelFuture
The result of an asynchronous
Channel I/O operation. |
interface |
ChannelProgressiveFuture
An special
ChannelFuture which is used to indicate the FileRegion transfer progress |
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<?> |
ThreadPerChannelEventLoopGroup.shutdownGracefully(long quietPeriod,
long timeout,
TimeUnit unit) |
Future<?> |
ThreadPerChannelEventLoopGroup.terminationFuture() |
Modifier and Type | Method and Description |
---|---|
ChannelProgressivePromise |
ChannelProgressivePromise.addListener(GenericFutureListener<? extends Future<? super Void>> listener) |
ChannelProgressivePromise |
DefaultChannelProgressivePromise.addListener(GenericFutureListener<? extends Future<? super Void>> listener) |
ChannelPromise |
ChannelPromise.addListener(GenericFutureListener<? extends Future<? super Void>> listener) |
ChannelFuture |
ChannelFuture.addListener(GenericFutureListener<? extends Future<? super Void>> listener) |
ChannelProgressiveFuture |
ChannelProgressiveFuture.addListener(GenericFutureListener<? extends Future<? super Void>> listener) |
ChannelPromise |
DefaultChannelPromise.addListener(GenericFutureListener<? extends Future<? super Void>> listener) |
ChannelProgressivePromise |
ChannelProgressivePromise.removeListener(GenericFutureListener<? extends Future<? super Void>> listener) |
ChannelProgressivePromise |
DefaultChannelProgressivePromise.removeListener(GenericFutureListener<? extends Future<? super Void>> listener) |
ChannelPromise |
ChannelPromise.removeListener(GenericFutureListener<? extends Future<? super Void>> listener) |
ChannelFuture |
ChannelFuture.removeListener(GenericFutureListener<? extends Future<? super Void>> listener) |
ChannelProgressiveFuture |
ChannelProgressiveFuture.removeListener(GenericFutureListener<? extends Future<? super Void>> listener) |
ChannelPromise |
DefaultChannelPromise.removeListener(GenericFutureListener<? extends Future<? super Void>> listener) |
Modifier and Type | Interface and Description |
---|---|
interface |
ChannelGroupFuture
The result of an asynchronous
ChannelGroup operation. |
Modifier and Type | Method and Description |
---|---|
ChannelGroupFuture |
ChannelGroupFuture.addListener(GenericFutureListener<? extends Future<? super Void>> listener) |
ChannelGroupFuture |
ChannelGroupFuture.removeListener(GenericFutureListener<? extends Future<? super Void>> listener) |
Modifier and Type | Method and Description |
---|---|
Future<Channel> |
ProxyHandler.connectFuture()
Returns a
Future that is notified when the connection to the destination has been established
or the connection attempt has failed. |
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()
|
Modifier and Type | Method and Description |
---|---|
Future<T> |
NameResolver.resolve(SocketAddress address)
Resolves the specified address.
|
Future<T> |
SimpleNameResolver.resolve(SocketAddress address) |
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)
Resolves the specified name into a
SocketAddress . |
Future<T> |
SimpleNameResolver.resolve(String inetHost,
int inetPort) |
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 |
---|---|
Future<DnsResponse> |
DnsNameResolver.query(DnsQuestion question)
Sends a DNS query with the specified question.
|
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)
Sends a DNS query with the specified question using the specified name server list.
|
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 |
GenericFutureListener<F extends Future<?>>
Listens to the result of a
Future . |
class |
PromiseAggregator<V,F extends Future<V>>
GenericFutureListener implementation which consolidates multiple Future s
into one, by listening to individual Future s and producing an aggregated result
(success/failure) when all Future s have completed. |
class |
PromiseNotifier<V,F extends Future<V>>
GenericFutureListener implementation which takes other Future s
and notifies them on completion. |
Modifier and Type | Interface and Description |
---|---|
interface |
ProgressiveFuture<V>
A
Future which is used to indicate the progress of an operation. |
interface |
ProgressivePromise<V>
Special
ProgressiveFuture which is writable. |
interface |
Promise<V>
Special
Future which is writable. |
interface |
ScheduledFuture<V>
The result of an scheduled asynchronous operation.
|
Modifier and Type | Class and Description |
---|---|
class |
DefaultProgressivePromise<V> |
class |
DefaultPromise<V> |
Modifier and Type | Method and Description |
---|---|
Future<V> |
Future.addListener(GenericFutureListener<? extends Future<? super V>> listener)
Adds the specified listener to this future.
|
Future<V> |
CompleteFuture.addListener(GenericFutureListener<? extends Future<? super V>> listener) |
Future<V> |
Future.addListeners(GenericFutureListener<? extends Future<? super V>>... listeners)
Adds the specified listeners to this future.
|
Future<V> |
CompleteFuture.addListeners(GenericFutureListener<? extends Future<? super V>>... listeners) |
Future<V> |
Future.await()
Waits for this future to be completed.
|
Future<V> |
CompleteFuture.await() |
Future<V> |
Future.awaitUninterruptibly()
Waits for this future to be completed without
interruption.
|
Future<V> |
CompleteFuture.awaitUninterruptibly() |
<V> Future<V> |
EventExecutor.newFailedFuture(Throwable cause)
Create a new
Future which is marked as failed already. |
<V> Future<V> |
AbstractEventExecutor.newFailedFuture(Throwable cause) |
<V> Future<V> |
EventExecutor.newSucceededFuture(V result)
Create a new
Future which is marked as succeeded already. |
<V> Future<V> |
AbstractEventExecutor.newSucceededFuture(V result) |
Future<V> |
Future.removeListener(GenericFutureListener<? extends Future<? super V>> listener)
Removes the specified listener from this future.
|
Future<V> |
CompleteFuture.removeListener(GenericFutureListener<? extends Future<? super V>> listener) |
Future<V> |
Future.removeListeners(GenericFutureListener<? extends Future<? super V>>... listeners)
Removes the specified listeners from this future.
|
Future<V> |
CompleteFuture.removeListeners(GenericFutureListener<? extends Future<? super V>>... listeners) |
Future<?> |
AbstractEventExecutorGroup.shutdownGracefully() |
Future<?> |
AbstractEventExecutor.shutdownGracefully() |
Future<?> |
EventExecutorGroup.shutdownGracefully()
Shortcut method for
EventExecutorGroup.shutdownGracefully(long, long, TimeUnit) with sensible default values. |
Future<?> |
ImmediateEventExecutor.shutdownGracefully(long quietPeriod,
long timeout,
TimeUnit unit) |
Future<?> |
GlobalEventExecutor.shutdownGracefully(long quietPeriod,
long timeout,
TimeUnit unit) |
Future<?> |
SingleThreadEventExecutor.shutdownGracefully(long quietPeriod,
long timeout,
TimeUnit unit) |
Future<?> |
MultithreadEventExecutorGroup.shutdownGracefully(long quietPeriod,
long timeout,
TimeUnit unit) |
Future<?> |
EventExecutorGroup.shutdownGracefully(long quietPeriod,
long timeout,
TimeUnit unit)
Signals this executor that the caller wants the executor to be shut down.
|
<T> Future<T> |
AbstractEventExecutorGroup.submit(Callable<T> task) |
<T> Future<T> |
AbstractEventExecutor.submit(Callable<T> task) |
<T> Future<T> |
EventExecutorGroup.submit(Callable<T> task) |
Future<?> |
AbstractEventExecutorGroup.submit(Runnable task) |
Future<?> |
AbstractEventExecutor.submit(Runnable task) |
Future<?> |
EventExecutorGroup.submit(Runnable task) |
<T> Future<T> |
AbstractEventExecutorGroup.submit(Runnable task,
T result) |
<T> Future<T> |
AbstractEventExecutor.submit(Runnable task,
T result) |
<T> Future<T> |
EventExecutorGroup.submit(Runnable task,
T result) |
Future<V> |
FailedFuture.sync() |
Future<V> |
Future.sync()
Waits for this future until it is done, and rethrows the cause of the failure if this future
failed.
|
Future<V> |
CompleteFuture.sync() |
Future<V> |
FailedFuture.syncUninterruptibly() |
Future<V> |
Future.syncUninterruptibly()
Waits for this future until it is done, and rethrows the cause of the failure if this future
failed.
|
Future<V> |
CompleteFuture.syncUninterruptibly() |
Future<?> |
ImmediateEventExecutor.terminationFuture() |
Future<?> |
GlobalEventExecutor.terminationFuture() |
Future<?> |
SingleThreadEventExecutor.terminationFuture() |
Future<?> |
MultithreadEventExecutorGroup.terminationFuture() |
Future<?> |
EventExecutorGroup.terminationFuture()
Returns the
Future which is notified when all EventExecutor s managed by this
EventExecutorGroup have been terminated. |
Modifier and Type | Method and Description |
---|---|
protected static void |
DefaultPromise.notifyListener(EventExecutor eventExecutor,
Future<?> future,
GenericFutureListener<?> l) |
Modifier and Type | Method and Description |
---|---|
ProgressiveFuture<V> |
ProgressiveFuture.addListener(GenericFutureListener<? extends Future<? super V>> listener) |
ProgressivePromise<V> |
DefaultProgressivePromise.addListener(GenericFutureListener<? extends Future<? super V>> listener) |
ProgressivePromise<V> |
ProgressivePromise.addListener(GenericFutureListener<? extends Future<? super V>> listener) |
Future<V> |
Future.addListener(GenericFutureListener<? extends Future<? super V>> listener)
Adds the specified listener to this future.
|
Promise<V> |
Promise.addListener(GenericFutureListener<? extends Future<? super V>> listener) |
Future<V> |
CompleteFuture.addListener(GenericFutureListener<? extends Future<? super V>> listener) |
Promise<V> |
DefaultPromise.addListener(GenericFutureListener<? extends Future<? super V>> listener) |
ProgressiveFuture<V> |
ProgressiveFuture.removeListener(GenericFutureListener<? extends Future<? super V>> listener) |
ProgressivePromise<V> |
DefaultProgressivePromise.removeListener(GenericFutureListener<? extends Future<? super V>> listener) |
ProgressivePromise<V> |
ProgressivePromise.removeListener(GenericFutureListener<? extends Future<? super V>> listener) |
Future<V> |
Future.removeListener(GenericFutureListener<? extends Future<? super V>> listener)
Removes the specified listener from this future.
|
Promise<V> |
Promise.removeListener(GenericFutureListener<? extends Future<? super V>> listener) |
Future<V> |
CompleteFuture.removeListener(GenericFutureListener<? extends Future<? super V>> listener) |
Promise<V> |
DefaultPromise.removeListener(GenericFutureListener<? extends Future<? super V>> listener) |
Copyright © 2008–2015 The Netty Project. All rights reserved.