Uses of Interface
io.netty.util.concurrent.Future

Packages that use Future

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 Channels and perform bulk operations on them.
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.

Uses of Future in io.netty.channel

Subinterfaces of Future in io.netty.channel

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.

Classes in io.netty.channel that implement Future

Modifier and Type	Class and Description
class	DefaultChannelProgressivePromise The default ChannelProgressivePromise implementation.
class	DefaultChannelPromise The default ChannelPromise implementation.

Methods in io.netty.channel that return Future

Modifier and Type	Method and Description
Future<?>	ThreadPerChannelEventLoopGroup.shutdownGracefully(long quietPeriod, long timeout, java.util.concurrent.TimeUnit unit)
Future<?>	ThreadPerChannelEventLoopGroup.terminationFuture()

Method parameters in io.netty.channel with type arguments of type Future

Modifier and Type	Method and Description
ChannelPromise	DefaultChannelPromise.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
ChannelProgressivePromise	DefaultChannelProgressivePromise.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
ChannelPromise	ChannelPromise.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
ChannelProgressivePromise	ChannelProgressivePromise.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
ChannelProgressiveFuture	ChannelProgressiveFuture.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
ChannelFuture	ChannelFuture.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
ChannelPromise	DefaultChannelPromise.removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
ChannelProgressivePromise	DefaultChannelProgressivePromise.removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
ChannelPromise	ChannelPromise.removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
ChannelProgressivePromise	ChannelProgressivePromise.removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
ChannelProgressiveFuture	ChannelProgressiveFuture.removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
ChannelFuture	ChannelFuture.removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)

Uses of Future in io.netty.channel.group

Subinterfaces of Future in io.netty.channel.group

Modifier and Type	Interface and Description
interface	ChannelGroupFuture The result of an asynchronous ChannelGroup operation.

Method parameters in io.netty.channel.group with type arguments of type Future

Modifier and Type	Method and Description
ChannelGroupFuture	ChannelGroupFuture.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
ChannelGroupFuture	ChannelGroupFuture.removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)

Uses of Future in io.netty.channel.pool

Methods in io.netty.channel.pool that return Future

Modifier and Type	Method and Description
Future<Channel>	SimpleChannelPool.acquire()
Future<Channel>	ChannelPool.acquire() Acquire a Channel from this ChannelPool.
Future<Channel>	SimpleChannelPool.acquire(Promise<Channel> promise)
Future<Channel>	FixedChannelPool.acquire(Promise<Channel> promise)
Future<Channel>	ChannelPool.acquire(Promise<Channel> promise) Acquire a Channel from this ChannelPool.
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>	SimpleChannelPool.release(Channel channel)
Future<java.lang.Void>	ChannelPool.release(Channel channel) 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)
Future<java.lang.Void>	ChannelPool.release(Channel channel, Promise<java.lang.Void> promise) Release a Channel back to this ChannelPool.

Uses of Future in io.netty.handler.ssl

Methods in io.netty.handler.ssl that return Future

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.

Uses of Future in io.netty.util.concurrent

Classes in io.netty.util.concurrent with type parameters of type Future

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 Futures into one, by listening to individual Futures and producing an aggregated result (success/failure) when all Futures have completed.
class	PromiseNotifier<V,F extends Future<V>> GenericFutureListener implementation which takes other Promises and notifies them on completion.

Subinterfaces of Future in io.netty.util.concurrent

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.

Classes in io.netty.util.concurrent that implement Future

Modifier and Type	Class and Description
class	DefaultProgressivePromise<V>
class	DefaultPromise<V>

Methods in io.netty.util.concurrent that return Future

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>	UnorderedThreadPoolEventExecutor.newFailedFuture(java.lang.Throwable cause)
<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.newSucceededFuture(V result)
<V> Future<V>	EventExecutor.newSucceededFuture(V result) Create a new Future which is marked as successes already.
<V> Future<V>	AbstractEventExecutor.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<?>	UnorderedThreadPoolEventExecutor.shutdownGracefully()
Future<?>	EventExecutorGroup.shutdownGracefully() Shortcut method for EventExecutorGroup.shutdownGracefully(long, long, TimeUnit) with sensible default values.
Future<?>	AbstractEventExecutorGroup.shutdownGracefully()
Future<?>	AbstractEventExecutor.shutdownGracefully()
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<?>	MultithreadEventExecutorGroup.shutdownGracefully(long quietPeriod, long timeout, java.util.concurrent.TimeUnit unit)
Future<?>	ImmediateEventExecutor.shutdownGracefully(long quietPeriod, long timeout, java.util.concurrent.TimeUnit unit)
Future<?>	GlobalEventExecutor.shutdownGracefully(long quietPeriod, long timeout, java.util.concurrent.TimeUnit unit)
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.
<T> Future<T>	UnorderedThreadPoolEventExecutor.submit(java.util.concurrent.Callable<T> task)
<T> Future<T>	EventExecutorGroup.submit(java.util.concurrent.Callable<T> task)
<T> Future<T>	AbstractEventExecutorGroup.submit(java.util.concurrent.Callable<T> task)
<T> Future<T>	AbstractEventExecutor.submit(java.util.concurrent.Callable<T> task)
Future<?>	UnorderedThreadPoolEventExecutor.submit(java.lang.Runnable task)
Future<?>	EventExecutorGroup.submit(java.lang.Runnable task)
Future<?>	AbstractEventExecutorGroup.submit(java.lang.Runnable task)
Future<?>	AbstractEventExecutor.submit(java.lang.Runnable task)
<T> Future<T>	UnorderedThreadPoolEventExecutor.submit(java.lang.Runnable task, T result)
<T> Future<T>	EventExecutorGroup.submit(java.lang.Runnable task, T result)
<T> Future<T>	AbstractEventExecutorGroup.submit(java.lang.Runnable task, T result)
<T> Future<T>	AbstractEventExecutor.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<?>	UnorderedThreadPoolEventExecutor.terminationFuture()
Future<?>	SingleThreadEventExecutor.terminationFuture()
Future<?>	MultithreadEventExecutorGroup.terminationFuture()
Future<?>	ImmediateEventExecutor.terminationFuture()
Future<?>	GlobalEventExecutor.terminationFuture()
Future<?>	EventExecutorGroup.terminationFuture() Returns the Future which is notified when this executor has been terminated.

Methods in io.netty.util.concurrent with parameters of type Future

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.
void	UnaryPromiseNotifier.operationComplete(Future<T> future)

Method parameters in io.netty.util.concurrent with type arguments of type Future

Modifier and Type	Method and Description
Promise<V>	Promise.addListener(GenericFutureListener<? extends Future<? super V>> listener)
ProgressivePromise<V>	ProgressivePromise.addListener(GenericFutureListener<? extends Future<? super V>> listener)
ProgressiveFuture<V>	ProgressiveFuture.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>	DefaultPromise.addListener(GenericFutureListener<? extends Future<? super V>> listener)
ProgressivePromise<V>	DefaultProgressivePromise.addListener(GenericFutureListener<? extends Future<? super V>> listener)
Future<V>	CompleteFuture.addListener(GenericFutureListener<? extends Future<? super V>> listener)
Promise<V>	Promise.removeListener(GenericFutureListener<? extends Future<? super V>> listener)
ProgressivePromise<V>	ProgressivePromise.removeListener(GenericFutureListener<? extends Future<? super V>> listener)
ProgressiveFuture<V>	ProgressiveFuture.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.
Promise<V>	DefaultPromise.removeListener(GenericFutureListener<? extends Future<? super V>> listener)
ProgressivePromise<V>	DefaultProgressivePromise.removeListener(GenericFutureListener<? extends Future<? super V>> listener)
Future<V>	CompleteFuture.removeListener(GenericFutureListener<? extends Future<? super V>> listener)