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.local |
A virtual transport that enables the communication between the two
parties in the same virtual machine.
|
io.netty.channel.pool |
Implementations and API for
Channel pools. |
io.netty.handler.ssl |
SSL ·
TLS implementation based on
SSLEngine |
io.netty.util.concurrent |
Utility classes for concurrent / async tasks.
|
Modifier and Type | Class and Description |
---|---|
private static class |
AbstractBootstrap.PendingRegistrationPromise |
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 |
---|---|
(package private) static class |
AbstractChannel.CloseFuture |
(package private) class |
CompleteChannelFuture
A skeletal
ChannelFuture implementation which represents a
ChannelFuture which has been completed already. |
class |
DefaultChannelProgressivePromise
The default
ChannelProgressivePromise implementation. |
class |
DefaultChannelPromise
The default
ChannelPromise implementation. |
(package private) class |
FailedChannelFuture
The
CompleteChannelFuture which is failed already. |
(package private) class |
SucceededChannelFuture
The
CompleteChannelFuture which is succeeded already. |
(package private) class |
VoidChannelPromise |
Modifier and Type | Method and Description |
---|---|
Future<?> |
ThreadPerChannelEventLoopGroup.shutdownGracefully(long quietPeriod,
long timeout,
java.util.concurrent.TimeUnit unit) |
Future<?> |
ThreadPerChannelEventLoopGroup.terminationFuture() |
Modifier and Type | Method and Description |
---|---|
ChannelFuture |
ChannelFuture.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelProgressivePromise |
DefaultChannelProgressivePromise.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelProgressiveFuture |
ChannelProgressiveFuture.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelProgressivePromise |
ChannelProgressivePromise.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelFuture |
CompleteChannelFuture.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelPromise |
ChannelPromise.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelPromise |
DefaultChannelPromise.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
VoidChannelPromise |
VoidChannelPromise.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelFuture |
ChannelFuture.removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelProgressivePromise |
DefaultChannelProgressivePromise.removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelProgressiveFuture |
ChannelProgressiveFuture.removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelProgressivePromise |
ChannelProgressivePromise.removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelFuture |
CompleteChannelFuture.removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelPromise |
ChannelPromise.removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelPromise |
DefaultChannelPromise.removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
VoidChannelPromise |
VoidChannelPromise.removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
Modifier and Type | Method and Description |
---|---|
Future<?> |
EmbeddedEventLoop.shutdownGracefully(long quietPeriod,
long timeout,
java.util.concurrent.TimeUnit unit) |
Future<?> |
EmbeddedEventLoop.terminationFuture() |
Modifier and Type | Interface and Description |
---|---|
interface |
ChannelGroupFuture
The result of an asynchronous
ChannelGroup operation. |
Modifier and Type | Class and Description |
---|---|
(package private) class |
DefaultChannelGroupFuture
The default
ChannelGroupFuture implementation. |
Modifier and Type | Method and Description |
---|---|
DefaultChannelGroupFuture |
DefaultChannelGroupFuture.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelGroupFuture |
ChannelGroupFuture.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
DefaultChannelGroupFuture |
DefaultChannelGroupFuture.removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelGroupFuture |
ChannelGroupFuture.removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
Modifier and Type | Field and Description |
---|---|
private Future<?> |
LocalChannel.finishReadFuture |
Modifier and Type | Field and Description |
---|---|
private static java.util.concurrent.atomic.AtomicReferenceFieldUpdater<LocalChannel,Future> |
LocalChannel.FINISH_READ_FUTURE_UPDATER |
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> |
SimpleChannelPool.acquire(Promise<Channel> promise) |
Future<Channel> |
FixedChannelPool.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.
|
Future<java.lang.Boolean> |
ChannelHealthChecker.isHealthy(Channel channel)
Check if the given channel is healthy which means it can be used.
|
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> |
SimpleChannelPool.release(Channel channel,
Promise<java.lang.Void> promise) |
Future<java.lang.Void> |
FixedChannelPool.release(Channel channel,
Promise<java.lang.Void> promise) |
Modifier and Type | Method and Description |
---|---|
private void |
SimpleChannelPool.notifyHealthCheck(Future<java.lang.Boolean> future,
Channel ch,
Promise<Channel> promise) |
void |
FixedChannelPool.AcquireListener.operationComplete(Future<Channel> future) |
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 healty.
|
Modifier and Type | Class and Description |
---|---|
private class |
SslHandler.LazyChannelPromise |
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 | Interface and Description |
---|---|
interface |
GenericFutureListener<F extends Future<?>>
Listens to the result of a
Future . |
class |
PromiseAggregator<V,F extends Future<V>>
Deprecated.
Use
PromiseCombiner
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 Promise 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> |
(package private) static class |
ImmediateEventExecutor.ImmediateProgressivePromise<V> |
(package private) static class |
ImmediateEventExecutor.ImmediatePromise<V> |
(package private) class |
PromiseTask<V> |
(package private) class |
ScheduledFutureTask<V> |
private static class |
UnorderedThreadPoolEventExecutor.RunnableScheduledFutureTask<V> |
Modifier and Type | Field and Description |
---|---|
private Future<?> |
GlobalEventExecutor.terminationFuture |
private Future<?> |
ImmediateEventExecutor.terminationFuture |
Modifier and Type | Field and Description |
---|---|
private GenericFutureListener<Future<?>> |
PromiseCombiner.listener |
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(java.lang.Throwable cause)
Create a new
Future which is marked as fakued already. |
<V> Future<V> |
AbstractEventExecutor.newFailedFuture(java.lang.Throwable cause) |
<V> Future<V> |
UnorderedThreadPoolEventExecutor.newFailedFuture(java.lang.Throwable cause) |
<V> Future<V> |
EventExecutor.newSucceededFuture(V result)
Create a new
Future which is marked as successes already. |
<V> Future<V> |
AbstractEventExecutor.newSucceededFuture(V result) |
<V> Future<V> |
UnorderedThreadPoolEventExecutor.newSucceededFuture(V result) |
Future<V> |
Future.removeListener(GenericFutureListener<? extends Future<? super V>> listener)
Removes the first occurrence of 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 first occurrence for each of the listeners from this future.
|
Future<V> |
CompleteFuture.removeListeners(GenericFutureListener<? extends Future<? super V>>... listeners) |
Future<?> |
EventExecutorGroup.shutdownGracefully()
Shortcut method for
EventExecutorGroup.shutdownGracefully(long, long, TimeUnit) with sensible default values. |
Future<?> |
AbstractEventExecutor.shutdownGracefully() |
Future<?> |
UnorderedThreadPoolEventExecutor.shutdownGracefully() |
Future<?> |
AbstractEventExecutorGroup.shutdownGracefully() |
Future<?> |
EventExecutorGroup.shutdownGracefully(long quietPeriod,
long timeout,
java.util.concurrent.TimeUnit unit)
Signals this executor that the caller wants the executor to be shut down.
|
Future<?> |
UnorderedThreadPoolEventExecutor.shutdownGracefully(long quietPeriod,
long timeout,
java.util.concurrent.TimeUnit unit) |
Future<?> |
SingleThreadEventExecutor.shutdownGracefully(long quietPeriod,
long timeout,
java.util.concurrent.TimeUnit unit) |
Future<?> |
GlobalEventExecutor.shutdownGracefully(long quietPeriod,
long timeout,
java.util.concurrent.TimeUnit unit) |
Future<?> |
ImmediateEventExecutor.shutdownGracefully(long quietPeriod,
long timeout,
java.util.concurrent.TimeUnit unit) |
Future<?> |
MultithreadEventExecutorGroup.shutdownGracefully(long quietPeriod,
long timeout,
java.util.concurrent.TimeUnit unit) |
<T> Future<T> |
EventExecutorGroup.submit(java.util.concurrent.Callable<T> task) |
<T> Future<T> |
AbstractEventExecutor.submit(java.util.concurrent.Callable<T> task) |
<T> Future<T> |
UnorderedThreadPoolEventExecutor.submit(java.util.concurrent.Callable<T> task) |
<T> Future<T> |
AbstractEventExecutorGroup.submit(java.util.concurrent.Callable<T> task) |
Future<?> |
EventExecutorGroup.submit(java.lang.Runnable task) |
Future<?> |
AbstractEventExecutor.submit(java.lang.Runnable task) |
Future<?> |
UnorderedThreadPoolEventExecutor.submit(java.lang.Runnable task) |
Future<?> |
AbstractEventExecutorGroup.submit(java.lang.Runnable task) |
<T> Future<T> |
EventExecutorGroup.submit(java.lang.Runnable task,
T result) |
<T> Future<T> |
AbstractEventExecutor.submit(java.lang.Runnable task,
T result) |
<T> Future<T> |
UnorderedThreadPoolEventExecutor.submit(java.lang.Runnable task,
T result) |
<T> Future<T> |
AbstractEventExecutorGroup.submit(java.lang.Runnable task,
T result) |
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> |
FailedFuture.sync() |
Future<V> |
CompleteFuture.sync() |
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> |
FailedFuture.syncUninterruptibly() |
Future<V> |
CompleteFuture.syncUninterruptibly() |
Future<?> |
EventExecutorGroup.terminationFuture()
Returns the
Future which is notified when this executor has been terminated. |
Future<?> |
UnorderedThreadPoolEventExecutor.terminationFuture() |
Future<?> |
SingleThreadEventExecutor.terminationFuture() |
Future<?> |
GlobalEventExecutor.terminationFuture() |
Future<?> |
ImmediateEventExecutor.terminationFuture() |
Future<?> |
MultithreadEventExecutorGroup.terminationFuture() |
Modifier and Type | Method and Description |
---|---|
static <X> void |
UnaryPromiseNotifier.cascadeTo(Future<X> completedFuture,
Promise<? super X> promise) |
protected static void |
DefaultPromise.notifyListener(EventExecutor eventExecutor,
Future<?> future,
GenericFutureListener<?> listener)
Notify a listener that a future has completed.
|
private static void |
DefaultPromise.notifyListener0(Future future,
GenericFutureListener l) |
private static void |
DefaultPromise.notifyListenerWithStackOverFlowProtection(EventExecutor executor,
Future<?> future,
GenericFutureListener<?> listener)
The logic in this method should be identical to
DefaultPromise.notifyListeners() but
cannot share code because the listener(s) cannot be cached for an instance of DefaultPromise since the
listener(s) may be changed and is protected by a synchronized operation. |
void |
UnaryPromiseNotifier.operationComplete(Future<T> future) |
Modifier and Type | Method and Description |
---|---|
void |
DefaultFutureListeners.add(GenericFutureListener<? extends Future<?>> l) |
Promise<V> |
DefaultPromise.addListener(GenericFutureListener<? extends Future<? super V>> listener) |
ProgressivePromise<V> |
ProgressivePromise.addListener(GenericFutureListener<? extends Future<? super V>> listener) |
Promise<V> |
Promise.addListener(GenericFutureListener<? extends Future<? super V>> listener) |
ProgressivePromise<V> |
DefaultProgressivePromise.addListener(GenericFutureListener<? extends Future<? super V>> listener) |
Future<V> |
Future.addListener(GenericFutureListener<? extends Future<? super V>> listener)
Adds the specified listener to this future.
|
ProgressiveFuture<V> |
ProgressiveFuture.addListener(GenericFutureListener<? extends Future<? super V>> listener) |
Future<V> |
CompleteFuture.addListener(GenericFutureListener<? extends Future<? super V>> listener) |
private void |
DefaultPromise.addListener0(GenericFutureListener<? extends Future<? super V>> listener) |
void |
DefaultFutureListeners.remove(GenericFutureListener<? extends Future<?>> l) |
Promise<V> |
DefaultPromise.removeListener(GenericFutureListener<? extends Future<? super V>> listener) |
ProgressivePromise<V> |
ProgressivePromise.removeListener(GenericFutureListener<? extends Future<? super V>> listener) |
Promise<V> |
Promise.removeListener(GenericFutureListener<? extends Future<? super V>> listener) |
ProgressivePromise<V> |
DefaultProgressivePromise.removeListener(GenericFutureListener<? extends Future<? super V>> listener) |
Future<V> |
Future.removeListener(GenericFutureListener<? extends Future<? super V>> listener)
Removes the first occurrence of the specified listener from this future.
|
ProgressiveFuture<V> |
ProgressiveFuture.removeListener(GenericFutureListener<? extends Future<? super V>> listener) |
Future<V> |
CompleteFuture.removeListener(GenericFutureListener<? extends Future<? super V>> listener) |
private void |
DefaultPromise.removeListener0(GenericFutureListener<? extends Future<? super V>> listener) |
Constructor and Description |
---|
DefaultFutureListeners(GenericFutureListener<? extends Future<?>> first,
GenericFutureListener<? extends Future<?>> second) |
DefaultFutureListeners(GenericFutureListener<? extends Future<?>> first,
GenericFutureListener<? extends Future<?>> second) |