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.codec.http2 |
Handlers for sending and receiving HTTP/2 frames.
|
io.netty.handler.proxy |
Adds support for client connections via proxy protocols such as
SOCKS and
HTTP CONNECT tunneling
|
io.netty.handler.ssl |
SSL ·
TLS implementation based on
SSLEngine |
io.netty.resolver |
Resolves an arbitrary string that represents the name of an endpoint into an address.
|
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 |
Utility classes used across multiple packages.
|
io.netty.util.concurrent |
Utility classes for concurrent / async tasks.
|
Modifier and Type | Class and Description |
---|---|
(package 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 |
---|---|
ChannelProgressivePromise |
ChannelProgressivePromise.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
VoidChannelPromise |
VoidChannelPromise.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelPromise |
ChannelPromise.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelFuture |
ChannelFuture.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelProgressivePromise |
DefaultChannelProgressivePromise.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelPromise |
DefaultChannelPromise.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelProgressiveFuture |
ChannelProgressiveFuture.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelFuture |
CompleteChannelFuture.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelProgressivePromise |
ChannelProgressivePromise.removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
VoidChannelPromise |
VoidChannelPromise.removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelPromise |
ChannelPromise.removeListener(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) |
ChannelPromise |
DefaultChannelPromise.removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelProgressiveFuture |
ChannelProgressiveFuture.removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelFuture |
CompleteChannelFuture.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. |
(package private) class |
VoidChannelGroupFuture |
Modifier and Type | Method and Description |
---|---|
DefaultChannelGroupFuture |
DefaultChannelGroupFuture.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelGroupFuture |
VoidChannelGroupFuture.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 |
VoidChannelGroupFuture.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> |
SimpleChannelPool.acquire() |
Future<Channel> |
ChannelPool.acquire()
Acquire a
Channel from this ChannelPool . |
Future<Channel> |
SimpleChannelPool.acquire(Promise<Channel> promise) |
Future<Channel> |
ChannelPool.acquire(Promise<Channel> promise)
Acquire a
Channel from this ChannelPool . |
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> |
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> |
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) |
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 healthy.
|
Modifier and Type | Class and Description |
---|---|
(package private) static class |
Http2CodecUtil.SimpleChannelPromiseAggregator
Provides the ability to associate the outcome of multiple
ChannelPromise
objects into a single ChannelPromise object. |
Modifier and Type | Method and Description |
---|---|
Future<java.lang.Void> |
DefaultHttp2Connection.close(Promise<java.lang.Void> promise) |
Future<java.lang.Void> |
Http2Connection.close(Promise<java.lang.Void> promise)
Close this connection.
|
Modifier and Type | Class and Description |
---|---|
private class |
ProxyHandler.LazyChannelPromise |
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 | 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. |
protected Future<SslContext> |
SniHandler.lookup(ChannelHandlerContext ctx,
java.lang.String hostname)
The default implementation will simply call
AsyncMapping.map(Object, Promise) but
users can override this method to implement custom behavior. |
protected abstract Future<T> |
AbstractSniHandler.lookup(ChannelHandlerContext ctx,
java.lang.String hostname)
Kicks off a lookup for the given SNI value and returns a
Future which in turn will
notify the AbstractSniHandler.onLookupComplete(ChannelHandlerContext, String, Future) on completion. |
Future<SslContext> |
SniHandler.AsyncMappingAdapter.map(java.lang.String input,
Promise<SslContext> promise) |
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 |
---|---|
protected void |
SniHandler.onLookupComplete(ChannelHandlerContext ctx,
java.lang.String hostname,
Future<SslContext> future) |
protected abstract void |
AbstractSniHandler.onLookupComplete(ChannelHandlerContext ctx,
java.lang.String hostname,
Future<T> future)
Called upon completion of the
AbstractSniHandler.lookup(ChannelHandlerContext, String) Future . |
Modifier and Type | Method and Description |
---|---|
Future<T> |
AddressResolver.resolve(java.net.SocketAddress address)
Resolves the specified address.
|
Future<T> |
AbstractAddressResolver.resolve(java.net.SocketAddress address) |
Future<T> |
AddressResolver.resolve(java.net.SocketAddress address,
Promise<T> promise)
Resolves the specified address.
|
Future<T> |
AbstractAddressResolver.resolve(java.net.SocketAddress address,
Promise<T> promise) |
Future<T> |
SimpleNameResolver.resolve(java.lang.String inetHost) |
Future<T> |
NameResolver.resolve(java.lang.String inetHost)
Resolves the specified name into an address.
|
Future<T> |
SimpleNameResolver.resolve(java.lang.String inetHost,
Promise<T> promise) |
Future<T> |
NameResolver.resolve(java.lang.String inetHost,
Promise<T> promise)
Resolves the specified name into an address.
|
Future<java.util.List<T>> |
AddressResolver.resolveAll(java.net.SocketAddress address)
Resolves the specified address.
|
Future<java.util.List<T>> |
AbstractAddressResolver.resolveAll(java.net.SocketAddress address) |
Future<java.util.List<T>> |
AddressResolver.resolveAll(java.net.SocketAddress address,
Promise<java.util.List<T>> promise)
Resolves the specified address.
|
Future<java.util.List<T>> |
AbstractAddressResolver.resolveAll(java.net.SocketAddress address,
Promise<java.util.List<T>> promise) |
Future<java.util.List<T>> |
SimpleNameResolver.resolveAll(java.lang.String inetHost) |
Future<java.util.List<T>> |
NameResolver.resolveAll(java.lang.String inetHost)
Resolves the specified host name and port into a list of address.
|
Future<java.util.List<T>> |
SimpleNameResolver.resolveAll(java.lang.String inetHost,
Promise<java.util.List<T>> promise) |
Future<java.util.List<T>> |
NameResolver.resolveAll(java.lang.String inetHost,
Promise<java.util.List<T>> promise)
Resolves the specified host name and port into a list of address.
|
Modifier and Type | Field and Description |
---|---|
(package private) Future<Channel> |
DnsNameResolver.channelFuture |
Modifier and Type | Field and Description |
---|---|
private java.util.Set<Future<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>>> |
DnsNameResolverContext.queriesInProgress |
Modifier and Type | Method and Description |
---|---|
Future<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>> |
DnsNameResolver.query(DnsQuestion question)
Sends a DNS query with the specified question.
|
Future<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>> |
DnsNameResolver.query(DnsQuestion question,
java.lang.Iterable<DnsRecord> additionals)
Sends a DNS query with the specified question with additional records.
|
Future<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>> |
DnsNameResolver.query(DnsQuestion question,
Promise<AddressedEnvelope<? extends DnsResponse,java.net.InetSocketAddress>> promise)
Sends a DNS query with the specified question.
|
Future<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>> |
DnsNameResolver.query(java.net.InetSocketAddress nameServerAddr,
DnsQuestion question)
Sends a DNS query with the specified question using the specified name server list.
|
Future<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>> |
DnsNameResolver.query(java.net.InetSocketAddress nameServerAddr,
DnsQuestion question,
java.lang.Iterable<DnsRecord> additionals)
Sends a DNS query with the specified question with additional records using the specified name server list.
|
Future<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>> |
DnsNameResolver.query(java.net.InetSocketAddress nameServerAddr,
DnsQuestion question,
java.lang.Iterable<DnsRecord> additionals,
Promise<AddressedEnvelope<? extends DnsResponse,java.net.InetSocketAddress>> promise)
Sends a DNS query with the specified question with additional records using the specified name server list.
|
Future<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>> |
DnsNameResolver.query(java.net.InetSocketAddress nameServerAddr,
DnsQuestion question,
Promise<AddressedEnvelope<? extends DnsResponse,java.net.InetSocketAddress>> promise)
Sends a DNS query with the specified question using the specified name server list.
|
(package private) Future<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>> |
DnsNameResolver.query0(java.net.InetSocketAddress nameServerAddr,
DnsQuestion question,
DnsRecord[] additionals,
ChannelPromise writePromise,
Promise<AddressedEnvelope<? extends DnsResponse,java.net.InetSocketAddress>> promise) |
(package private) Future<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>> |
DnsNameResolver.query0(java.net.InetSocketAddress nameServerAddr,
DnsQuestion question,
DnsRecord[] additionals,
Promise<AddressedEnvelope<? extends DnsResponse,java.net.InetSocketAddress>> promise) |
Future<T> |
InflightNameResolver.resolve(java.lang.String inetHost) |
Future<java.net.InetAddress> |
DnsNameResolver.resolve(java.lang.String inetHost,
java.lang.Iterable<DnsRecord> additionals)
Resolves the specified name into an address.
|
Future<java.net.InetAddress> |
DnsNameResolver.resolve(java.lang.String inetHost,
java.lang.Iterable<DnsRecord> additionals,
Promise<java.net.InetAddress> promise)
Resolves the specified name into an address.
|
Future<java.util.List<T>> |
InflightNameResolver.resolveAll(java.lang.String inetHost) |
Future<java.util.List<java.net.InetAddress>> |
DnsNameResolver.resolveAll(java.lang.String inetHost,
java.lang.Iterable<DnsRecord> additionals)
Resolves the specified host name and port into a list of address.
|
Future<java.util.List<java.net.InetAddress>> |
DnsNameResolver.resolveAll(java.lang.String inetHost,
java.lang.Iterable<DnsRecord> additionals,
Promise<java.util.List<java.net.InetAddress>> promise)
Resolves the specified host name and port into a list of address.
|
Modifier and Type | Method and Description |
---|---|
private static <T> void |
InflightNameResolver.transferResult(Future<T> src,
Promise<T> dst) |
Modifier and Type | Method and Description |
---|---|
Future<OUT> |
AsyncMapping.map(IN input,
Promise<OUT> promise)
Returns the
Future that will provide the result of the mapping. |
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<?> |
ImmediateEventExecutor.terminationFuture |
private Future<?> |
GlobalEventExecutor.terminationFuture |
Modifier and Type | Field and Description |
---|---|
private GenericFutureListener<Future<?>> |
PromiseCombiner.listener |
Modifier and Type | Method and Description |
---|---|
Future<V> |
CompleteFuture.addListener(GenericFutureListener<? extends Future<? super V>> listener) |
Future<V> |
Future.addListener(GenericFutureListener<? extends Future<? super V>> listener)
Adds the specified listener to this future.
|
Future<V> |
CompleteFuture.addListeners(GenericFutureListener<? extends Future<? super V>>... listeners) |
Future<V> |
Future.addListeners(GenericFutureListener<? extends Future<? super V>>... listeners)
Adds the specified listeners to this future.
|
Future<V> |
CompleteFuture.await() |
Future<V> |
Future.await()
Waits for this future to be completed.
|
Future<V> |
CompleteFuture.awaitUninterruptibly() |
Future<V> |
Future.awaitUninterruptibly()
Waits for this future to be completed without
interruption.
|
<V> Future<V> |
EventExecutor.newFailedFuture(java.lang.Throwable cause)
Create a new
Future which is marked as failed already. |
<V> Future<V> |
UnorderedThreadPoolEventExecutor.newFailedFuture(java.lang.Throwable cause) |
<V> Future<V> |
AbstractEventExecutor.newFailedFuture(java.lang.Throwable cause) |
<V> Future<V> |
EventExecutor.newSucceededFuture(V result)
Create a new
Future which is marked as succeeded already. |
<V> Future<V> |
UnorderedThreadPoolEventExecutor.newSucceededFuture(V result) |
<V> Future<V> |
AbstractEventExecutor.newSucceededFuture(V result) |
Future<V> |
CompleteFuture.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.
|
Future<V> |
CompleteFuture.removeListeners(GenericFutureListener<? extends Future<? super V>>... listeners) |
Future<V> |
Future.removeListeners(GenericFutureListener<? extends Future<? super V>>... listeners)
Removes the first occurrence for each of the listeners from this future.
|
Future<?> |
AbstractEventExecutorGroup.shutdownGracefully() |
Future<?> |
NonStickyEventExecutorGroup.shutdownGracefully() |
Future<?> |
UnorderedThreadPoolEventExecutor.shutdownGracefully() |
Future<?> |
EventExecutorGroup.shutdownGracefully()
Shortcut method for
EventExecutorGroup.shutdownGracefully(long, long, TimeUnit) with sensible default values. |
Future<?> |
AbstractEventExecutor.shutdownGracefully() |
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<?> |
NonStickyEventExecutorGroup.shutdownGracefully(long quietPeriod,
long timeout,
java.util.concurrent.TimeUnit unit) |
Future<?> |
NonStickyEventExecutorGroup.NonStickyOrderedEventExecutor.shutdownGracefully(long quietPeriod,
long timeout,
java.util.concurrent.TimeUnit unit) |
Future<?> |
MultithreadEventExecutorGroup.shutdownGracefully(long quietPeriod,
long timeout,
java.util.concurrent.TimeUnit unit) |
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<?> |
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> |
AbstractEventExecutorGroup.submit(java.util.concurrent.Callable<T> task) |
<T> Future<T> |
NonStickyEventExecutorGroup.submit(java.util.concurrent.Callable<T> task) |
<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> |
AbstractEventExecutor.submit(java.util.concurrent.Callable<T> task) |
Future<?> |
AbstractEventExecutorGroup.submit(java.lang.Runnable task) |
Future<?> |
NonStickyEventExecutorGroup.submit(java.lang.Runnable task) |
Future<?> |
UnorderedThreadPoolEventExecutor.submit(java.lang.Runnable task) |
Future<?> |
EventExecutorGroup.submit(java.lang.Runnable task) |
Future<?> |
AbstractEventExecutor.submit(java.lang.Runnable task) |
<T> Future<T> |
AbstractEventExecutorGroup.submit(java.lang.Runnable task,
T result) |
<T> Future<T> |
NonStickyEventExecutorGroup.submit(java.lang.Runnable task,
T result) |
<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> |
AbstractEventExecutor.submit(java.lang.Runnable task,
T result) |
Future<V> |
CompleteFuture.sync() |
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.syncUninterruptibly() |
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<?> |
ImmediateEventExecutor.terminationFuture() |
Future<?> |
GlobalEventExecutor.terminationFuture() |
Future<?> |
NonStickyEventExecutorGroup.terminationFuture() |
Future<?> |
NonStickyEventExecutorGroup.NonStickyOrderedEventExecutor.terminationFuture() |
Future<?> |
MultithreadEventExecutorGroup.terminationFuture() |
Future<?> |
UnorderedThreadPoolEventExecutor.terminationFuture() |
Future<?> |
SingleThreadEventExecutor.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 |
---|---|
void |
PromiseCombiner.add(Future future)
Adds a new future to be combined.
|
void |
PromiseCombiner.addAll(Future... futures)
Adds new futures to be combined.
|
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) |
ProgressiveFuture<V> |
ProgressiveFuture.addListener(GenericFutureListener<? extends Future<? super V>> listener) |
Future<V> |
CompleteFuture.addListener(GenericFutureListener<? extends Future<? super V>> listener) |
Promise<V> |
Promise.addListener(GenericFutureListener<? extends Future<? super V>> listener) |
Promise<V> |
DefaultPromise.addListener(GenericFutureListener<? extends Future<? super V>> listener) |
ProgressivePromise<V> |
ProgressivePromise.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.
|
private void |
DefaultPromise.addListener0(GenericFutureListener<? extends Future<? super V>> listener) |
void |
DefaultFutureListeners.remove(GenericFutureListener<? extends Future<?>> l) |
ProgressiveFuture<V> |
ProgressiveFuture.removeListener(GenericFutureListener<? extends Future<? super V>> listener) |
Future<V> |
CompleteFuture.removeListener(GenericFutureListener<? extends Future<? super V>> listener) |
Promise<V> |
Promise.removeListener(GenericFutureListener<? extends Future<? super V>> listener) |
Promise<V> |
DefaultPromise.removeListener(GenericFutureListener<? extends Future<? super V>> listener) |
ProgressivePromise<V> |
ProgressivePromise.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.
|
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) |