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.group |
A channel registry which helps a user maintain the list of open
Channel s and perform bulk operations on them. |
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.
|
io.netty.util.internal |
Internal-use-only utilities which is not allowed to be used
outside Netty.
|
Modifier and Type | Class and Description |
---|---|
(package private) static class |
AbstractBootstrap.PendingRegistrationPromise |
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 |
---|---|
(package private) static class |
AbstractChannel.CloseFuture |
class |
DefaultChannelProgressivePromise
The default
ChannelProgressivePromise implementation. |
class |
DefaultChannelPromise
The default
ChannelPromise implementation. |
(package private) class |
VoidChannelPromise |
Modifier and Type | Field and Description |
---|---|
private Promise<?> |
ThreadPerChannelEventLoopGroup.terminationFuture |
Modifier and Type | Class and Description |
---|---|
(package private) class |
DefaultChannelGroupFuture
The default
ChannelGroupFuture implementation. |
Modifier and Type | Field and Description |
---|---|
private Promise<Channel> |
FixedChannelPool.AcquireListener.originalPromise |
(package private) Promise<Channel> |
FixedChannelPool.AcquireTask.promise |
Modifier and Type | Method and Description |
---|---|
Future<Channel> |
FixedChannelPool.acquire(Promise<Channel> promise) |
Future<Channel> |
ChannelPool.acquire(Promise<Channel> promise)
Acquire a
Channel from this ChannelPool . |
Future<Channel> |
SimpleChannelPool.acquire(Promise<Channel> promise) |
private void |
FixedChannelPool.acquire0(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.
|
private static void |
SimpleChannelPool.closeAndFail(Channel channel,
java.lang.Throwable cause,
Promise<?> promise) |
private void |
SimpleChannelPool.doHealthCheck(Channel ch,
Promise<Channel> promise) |
private void |
SimpleChannelPool.doHealthCheckOnRelease(Channel channel,
Promise<java.lang.Void> promise) |
private void |
SimpleChannelPool.doReleaseChannel(Channel channel,
Promise<java.lang.Void> promise) |
private void |
SimpleChannelPool.notifyConnect(ChannelFuture future,
Promise<Channel> promise) |
private void |
SimpleChannelPool.notifyHealthCheck(Future<java.lang.Boolean> future,
Channel ch,
Promise<Channel> 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 . |
Future<java.lang.Void> |
SimpleChannelPool.release(Channel channel,
Promise<java.lang.Void> promise) |
private void |
SimpleChannelPool.releaseAndOffer(Channel channel,
Promise<java.lang.Void> promise) |
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.
|
Constructor and Description |
---|
AcquireListener(Promise<Channel> originalPromise) |
AcquireTask(Promise<Channel> promise) |
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 | Field and Description |
---|---|
(package private) Promise<java.lang.Void> |
DefaultHttp2Connection.closePromise |
Modifier and Type | Method and Description |
---|---|
Future<java.lang.Void> |
Http2Connection.close(Promise<java.lang.Void> promise)
Close this connection.
|
Future<java.lang.Void> |
DefaultHttp2Connection.close(Promise<java.lang.Void> promise) |
Modifier and Type | Class and Description |
---|---|
private class |
ProxyHandler.LazyChannelPromise |
Modifier and Type | Class and Description |
---|---|
private class |
SslHandler.LazyChannelPromise |
Modifier and Type | Field and Description |
---|---|
private Promise<Channel> |
SslHandler.handshakePromise |
Modifier and Type | Method and Description |
---|---|
private void |
SslHandler.handshake(Promise<Channel> newHandshakePromise)
Performs TLS (re)negotiation.
|
Future<SslContext> |
SniHandler.AsyncMappingAdapter.map(java.lang.String input,
Promise<SslContext> promise) |
Future<Channel> |
SslHandler.renegotiate(Promise<Channel> promise)
Performs TLS renegotiation.
|
Modifier and Type | Method and Description |
---|---|
protected void |
InetSocketAddressResolver.doResolve(java.net.InetSocketAddress unresolvedAddress,
Promise<java.net.InetSocketAddress> promise) |
protected void |
NoopAddressResolver.doResolve(java.net.SocketAddress unresolvedAddress,
Promise<java.net.SocketAddress> promise) |
protected void |
RoundRobinInetAddressResolver.doResolve(java.lang.String inetHost,
Promise<java.net.InetAddress> promise) |
protected void |
DefaultNameResolver.doResolve(java.lang.String inetHost,
Promise<java.net.InetAddress> promise) |
protected void |
CompositeNameResolver.doResolve(java.lang.String inetHost,
Promise<T> promise) |
protected abstract void |
SimpleNameResolver.doResolve(java.lang.String inetHost,
Promise<T> promise)
Invoked by
SimpleNameResolver.resolve(String) to perform the actual name resolution. |
protected abstract void |
AbstractAddressResolver.doResolve(T unresolvedAddress,
Promise<T> promise)
Invoked by
AbstractAddressResolver.resolve(SocketAddress) to perform the actual name
resolution. |
protected void |
InetSocketAddressResolver.doResolveAll(java.net.InetSocketAddress unresolvedAddress,
Promise<java.util.List<java.net.InetSocketAddress>> promise) |
protected void |
NoopAddressResolver.doResolveAll(java.net.SocketAddress unresolvedAddress,
Promise<java.util.List<java.net.SocketAddress>> promise) |
protected void |
RoundRobinInetAddressResolver.doResolveAll(java.lang.String inetHost,
Promise<java.util.List<java.net.InetAddress>> promise) |
protected void |
DefaultNameResolver.doResolveAll(java.lang.String inetHost,
Promise<java.util.List<java.net.InetAddress>> promise) |
protected void |
CompositeNameResolver.doResolveAll(java.lang.String inetHost,
Promise<java.util.List<T>> promise) |
protected abstract void |
SimpleNameResolver.doResolveAll(java.lang.String inetHost,
Promise<java.util.List<T>> promise)
Invoked by
SimpleNameResolver.resolveAll(String) to perform the actual name resolution. |
protected abstract void |
AbstractAddressResolver.doResolveAll(T unresolvedAddress,
Promise<java.util.List<T>> promise)
Invoked by
AbstractAddressResolver.resolveAll(SocketAddress) to perform the actual name
resolution. |
private void |
CompositeNameResolver.doResolveAllRec(java.lang.String inetHost,
Promise<java.util.List<T>> promise,
int resolverIndex,
java.lang.Throwable lastFailure) |
private void |
CompositeNameResolver.doResolveRec(java.lang.String inetHost,
Promise<T> promise,
int resolverIndex,
java.lang.Throwable lastFailure) |
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,
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,
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,
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 |
---|---|
private Promise<Channel> |
DnsNameResolver.DnsResponseHandler.channelActivePromise |
private Promise<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>> |
DnsQueryContext.promise |
Modifier and Type | Field and Description |
---|---|
private java.util.concurrent.ConcurrentMap<java.lang.String,Promise<java.util.List<T>>> |
InflightNameResolver.resolveAllsInProgress |
private java.util.concurrent.ConcurrentMap<java.lang.String,Promise<java.util.List<java.net.InetAddress>>> |
DnsAddressResolverGroup.resolveAllsInProgress |
private java.util.concurrent.ConcurrentMap<java.lang.String,Promise<T>> |
InflightNameResolver.resolvesInProgress |
private java.util.concurrent.ConcurrentMap<java.lang.String,Promise<java.net.InetAddress>> |
DnsAddressResolverGroup.resolvesInProgress |
Modifier and Type | Method and Description |
---|---|
private static Promise<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>> |
DnsNameResolver.cast(Promise<?> promise) |
private <U> Promise<U> |
InflightNameResolver.resolve(java.util.concurrent.ConcurrentMap<java.lang.String,Promise<U>> resolveMap,
java.lang.String inetHost,
Promise<U> promise,
boolean resolveAll) |
Promise<T> |
InflightNameResolver.resolve(java.lang.String inetHost,
Promise<T> promise) |
Promise<java.util.List<T>> |
InflightNameResolver.resolveAll(java.lang.String inetHost,
Promise<java.util.List<T>> promise) |
Modifier and Type | Method and Description |
---|---|
private static Promise<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>> |
DnsNameResolver.cast(Promise<?> promise) |
protected void |
DnsNameResolver.doResolve(java.lang.String inetHost,
DnsRecord[] additionals,
Promise<java.net.InetAddress> promise,
DnsCache resolveCache)
Hook designed for extensibility so one can pass a different cache on each resolution attempt
instead of using the global one.
|
protected void |
DnsNameResolver.doResolve(java.lang.String inetHost,
Promise<java.net.InetAddress> promise) |
protected void |
DnsNameResolver.doResolveAll(java.lang.String inetHost,
DnsRecord[] additionals,
Promise<java.util.List<java.net.InetAddress>> promise,
DnsCache resolveCache)
Hook designed for extensibility so one can pass a different cache on each resolution attempt
instead of using the global one.
|
protected void |
DnsNameResolver.doResolveAll(java.lang.String inetHost,
Promise<java.util.List<java.net.InetAddress>> promise) |
private boolean |
DnsNameResolver.doResolveAllCached(java.lang.String hostname,
DnsRecord[] additionals,
Promise<java.util.List<java.net.InetAddress>> promise,
DnsCache resolveCache) |
private void |
DnsNameResolver.doResolveAllUncached(java.lang.String hostname,
DnsRecord[] additionals,
Promise<java.util.List<java.net.InetAddress>> promise,
DnsCache resolveCache) |
private boolean |
DnsNameResolver.doResolveCached(java.lang.String hostname,
DnsRecord[] additionals,
Promise<java.net.InetAddress> promise,
DnsCache resolveCache) |
private void |
DnsNameResolver.doResolveUncached(java.lang.String hostname,
DnsRecord[] additionals,
Promise<java.net.InetAddress> promise,
DnsCache resolveCache) |
(package private) boolean |
DnsNameResolver.SingleResolverContext.finishResolve(java.lang.Class<? extends java.net.InetAddress> addressType,
java.util.List<DnsCacheEntry> resolvedEntries,
Promise<java.net.InetAddress> promise) |
(package private) boolean |
DnsNameResolver.ListResolverContext.finishResolve(java.lang.Class<? extends java.net.InetAddress> addressType,
java.util.List<DnsCacheEntry> resolvedEntries,
Promise<java.util.List<java.net.InetAddress>> promise) |
(package private) abstract boolean |
DnsNameResolverContext.finishResolve(java.lang.Class<? extends java.net.InetAddress> addressType,
java.util.List<DnsCacheEntry> resolvedEntries,
Promise<T> promise) |
private void |
DnsNameResolverContext.finishResolve(Promise<T> promise) |
private void |
DnsNameResolverContext.followCname(java.lang.String cname,
DnsQueryLifecycleObserver queryLifecycleObserver,
Promise<T> promise) |
private boolean |
DnsNameResolverContext.handleRedirect(DnsQuestion question,
AddressedEnvelope<DnsResponse,java.net.InetSocketAddress> envelope,
DnsQueryLifecycleObserver queryLifecycleObserver,
Promise<T> promise)
Handles a redirect answer if needed and returns
true if a redirect query has been made. |
private void |
DnsNameResolverContext.internalResolve(Promise<T> promise) |
(package private) void |
DnsNameResolverContext.onResponse(DnsServerAddressStream nameServerAddrStream,
int nameServerAddrStreamIndex,
DnsQuestion question,
AddressedEnvelope<DnsResponse,java.net.InetSocketAddress> envelope,
DnsQueryLifecycleObserver queryLifecycleObserver,
Promise<T> promise) |
private void |
DnsNameResolverContext.onResponseAorAAAA(DnsRecordType qType,
DnsQuestion question,
AddressedEnvelope<DnsResponse,java.net.InetSocketAddress> envelope,
DnsQueryLifecycleObserver queryLifecycleObserver,
Promise<T> promise) |
private void |
DnsNameResolverContext.onResponseCNAME(DnsQuestion question,
AddressedEnvelope<DnsResponse,java.net.InetSocketAddress> envelope,
DnsQueryLifecycleObserver queryLifecycleObserver,
Promise<T> promise) |
private void |
DnsNameResolverContext.onResponseCNAME(DnsQuestion question,
AddressedEnvelope<DnsResponse,java.net.InetSocketAddress> response,
java.util.Map<java.lang.String,java.lang.String> cnames,
DnsQueryLifecycleObserver queryLifecycleObserver,
Promise<T> promise) |
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.
|
private void |
DnsNameResolverContext.query(DnsServerAddressStream nameServerAddrStream,
int nameServerAddrStreamIndex,
DnsQuestion question,
DnsQueryLifecycleObserver queryLifecycleObserver,
Promise<T> promise) |
private void |
DnsNameResolverContext.query(DnsServerAddressStream nameServerAddrStream,
int nameServerAddrStreamIndex,
DnsQuestion question,
Promise<T> promise) |
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.
|
private boolean |
DnsNameResolverContext.query(java.lang.String hostname,
DnsRecordType type,
DnsServerAddressStream dnsServerAddressStream,
Promise<T> promise) |
(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) |
private <U> Promise<U> |
InflightNameResolver.resolve(java.util.concurrent.ConcurrentMap<java.lang.String,Promise<U>> resolveMap,
java.lang.String inetHost,
Promise<U> promise,
boolean resolveAll) |
(package private) void |
DnsNameResolverContext.resolve(Promise<T> promise) |
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.
|
Promise<T> |
InflightNameResolver.resolve(java.lang.String inetHost,
Promise<T> promise) |
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.
|
Promise<java.util.List<T>> |
InflightNameResolver.resolveAll(java.lang.String inetHost,
Promise<java.util.List<T>> promise) |
private static <T> void |
InflightNameResolver.transferResult(Future<T> src,
Promise<T> dst) |
private static void |
DnsNameResolver.tryFailure(Promise<?> promise,
java.lang.Throwable cause) |
private static <T> void |
DnsNameResolver.trySuccess(Promise<T> promise,
T result) |
(package private) void |
DnsNameResolverContext.tryToFinishResolve(DnsServerAddressStream nameServerAddrStream,
int nameServerAddrStreamIndex,
DnsQuestion question,
DnsQueryLifecycleObserver queryLifecycleObserver,
Promise<T> promise) |
Modifier and Type | Method and Description |
---|---|
private <U> Promise<U> |
InflightNameResolver.resolve(java.util.concurrent.ConcurrentMap<java.lang.String,Promise<U>> resolveMap,
java.lang.String inetHost,
Promise<U> promise,
boolean resolveAll) |
Constructor and Description |
---|
DnsQueryContext(DnsNameResolver parent,
java.net.InetSocketAddress nameServerAddr,
DnsQuestion question,
DnsRecord[] additionals,
Promise<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>> promise) |
DnsResponseHandler(Promise<Channel> channelActivePromise) |
Constructor and Description |
---|
InflightNameResolver(EventExecutor executor,
NameResolver<T> delegate,
java.util.concurrent.ConcurrentMap<java.lang.String,Promise<T>> resolvesInProgress,
java.util.concurrent.ConcurrentMap<java.lang.String,Promise<java.util.List<T>>> resolveAllsInProgress) |
InflightNameResolver(EventExecutor executor,
NameResolver<T> delegate,
java.util.concurrent.ConcurrentMap<java.lang.String,Promise<T>> resolvesInProgress,
java.util.concurrent.ConcurrentMap<java.lang.String,Promise<java.util.List<T>>> resolveAllsInProgress) |
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 |
ProgressivePromise<V>
Special
ProgressiveFuture which is writable. |
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 Promise<java.lang.Void> |
PromiseCombiner.aggregatePromise |
private Promise<?> |
PromiseAggregator.aggregatePromise
Deprecated.
|
private Promise<? super T> |
UnaryPromiseNotifier.promise |
private Promise<? super V>[] |
PromiseNotifier.promises |
private Promise<?> |
MultithreadEventExecutorGroup.terminationFuture |
private Promise<?> |
SingleThreadEventExecutor.terminationFuture |
private Promise<?> |
UnorderedThreadPoolEventExecutor.terminationFuture |
Modifier and Type | Field and Description |
---|---|
private java.util.Set<Promise<V>> |
PromiseAggregator.pendingPromises
Deprecated.
|
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() |
<V> Promise<V> |
UnorderedThreadPoolEventExecutor.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(java.lang.Throwable cause)
Marks this future as a failure and notifies all
listeners.
|
Promise<V> |
DefaultPromise.setFailure(java.lang.Throwable cause) |
Promise<V> |
PromiseTask.setFailure(java.lang.Throwable cause) |
protected Promise<V> |
PromiseTask.setFailureInternal(java.lang.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> |
PromiseTask.setSuccess(V result) |
protected Promise<V> |
PromiseTask.setSuccessInternal(V result) |
Promise<V> |
Promise.sync() |
Promise<V> |
DefaultPromise.sync() |
Promise<V> |
Promise.syncUninterruptibly() |
Promise<V> |
DefaultPromise.syncUninterruptibly() |
Modifier and Type | Method and Description |
---|---|
void |
PromiseCombiner.add(Promise promise)
Deprecated.
Replaced by
PromiseCombiner.add(Future) . |
PromiseAggregator<V,F> |
PromiseAggregator.add(Promise<V>... promises)
Deprecated.
Add the given
Promise s to the aggregator. |
void |
PromiseCombiner.addAll(Promise... promises)
Deprecated.
Replaced by
PromiseCombiner.addAll(Future[]) |
static <X> void |
UnaryPromiseNotifier.cascadeTo(Future<X> completedFuture,
Promise<? super X> promise) |
void |
PromiseCombiner.finish(Promise<java.lang.Void> aggregatePromise)
Sets the promise to be notified when all combined futures have finished.
|
Constructor and Description |
---|
PromiseAggregator(Promise<java.lang.Void> aggregatePromise)
Deprecated.
|
PromiseAggregator(Promise<java.lang.Void> aggregatePromise,
boolean failPending)
Deprecated.
Creates a new instance.
|
PromiseNotifier(boolean logNotifyFailure,
Promise<? super V>... promises)
Create a new instance.
|
PromiseNotifier(Promise<? super V>... promises)
Create a new instance.
|
UnaryPromiseNotifier(Promise<? super T> promise) |
Modifier and Type | Field and Description |
---|---|
private Promise<java.lang.Void> |
PendingWrite.promise |
Modifier and Type | Method and Description |
---|---|
Promise<java.lang.Void> |
PendingWrite.promise() |
Promise<java.lang.Void> |
PendingWrite.recycleAndGet()
Recycle this instance and return the
Promise . |
Modifier and Type | Method and Description |
---|---|
static PendingWrite |
PendingWrite.newInstance(java.lang.Object msg,
Promise<java.lang.Void> promise)
Create a new empty
RecyclableArrayList instance |
static void |
PromiseNotificationUtil.tryCancel(Promise<?> p,
InternalLogger logger)
|
static void |
PromiseNotificationUtil.tryFailure(Promise<?> p,
java.lang.Throwable cause,
InternalLogger logger)
|
static <V> void |
PromiseNotificationUtil.trySuccess(Promise<? super V> p,
V result,
InternalLogger logger)
|