Uses of Interface
io.netty.util.concurrent.Promise
Packages that use Promise
Package
Description
The helper classes with fluent API which enable an easy implementation of
typical client side and server side channel initialization.
The core channel API which is asynchronous and event-driven abstraction of
various transports such as a
NIO Channel.
A channel registry which helps a user maintain the list of open
Channel
s and perform bulk operations on them.Implementations and API for
Channel
pools.Handlers for sending and receiving HTTP/2 frames.
Adds support for client connections via proxy protocols such as
SOCKS and
HTTP CONNECT tunneling
Certificate validation using OCSP
Resolves an arbitrary string that represents the name of an endpoint into an address.
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.
Utility classes used across multiple packages.
Utility classes for concurrent / async tasks.
Internal-use-only utilities which is not allowed to be used
outside Netty.
-
Uses of Promise in io.netty.bootstrap
Classes in io.netty.bootstrap that implement PromiseModifier and TypeClassDescription(package private) static final class
-
Uses of Promise in io.netty.channel
Subinterfaces of Promise in io.netty.channelModifier and TypeInterfaceDescriptioninterface
SpecialChannelPromise
which will be notified once the associated bytes is transferring.interface
SpecialChannelFuture
which is writable.Classes in io.netty.channel that implement PromiseModifier and TypeClassDescription(package private) static final class
class
The defaultChannelProgressivePromise
implementation.class
The defaultChannelPromise
implementation.final class
final class
Fields in io.netty.channel declared as PromiseModifier and TypeFieldDescriptionprivate final Promise
<?> ThreadPerChannelEventLoopGroup.terminationFuture
Deprecated. -
Uses of Promise in io.netty.channel.group
Classes in io.netty.channel.group that implement PromiseModifier and TypeClassDescription(package private) final class
The defaultChannelGroupFuture
implementation. -
Uses of Promise in io.netty.channel.pool
Fields in io.netty.channel.pool declared as PromiseModifier and TypeFieldDescriptionFixedChannelPool.AcquireListener.originalPromise
FixedChannelPool.AcquireTask.promise
Methods in io.netty.channel.pool with parameters of type PromiseModifier and TypeMethodDescriptionAcquire aChannel
from thisChannelPool
.private void
SimpleChannelPool.acquireHealthyFromPoolOrNew
(Promise<Channel> promise) Tries to retrieve healthy channel from the pool if any or creates a new channel otherwise.private void
SimpleChannelPool.closeAndFail
(Channel channel, Throwable cause, Promise<?> promise) private void
SimpleChannelPool.doHealthCheck
(Channel channel, Promise<Channel> promise) private void
SimpleChannelPool.doHealthCheckOnRelease
(Channel channel, Promise<Void> promise) private void
SimpleChannelPool.doReleaseChannel
(Channel channel, Promise<Void> promise) private void
SimpleChannelPool.notifyConnect
(ChannelFuture future, Promise<Channel> promise) private void
SimpleChannelPool.notifyHealthCheck
(Future<Boolean> future, Channel channel, Promise<Channel> promise) Release aChannel
back to thisChannelPool
.private void
SimpleChannelPool.releaseAndOffer
(Channel channel, Promise<Void> promise) private void
SimpleChannelPool.releaseAndOfferIfHealthy
(Channel channel, Promise<Void> promise, Future<Boolean> future) Adds the channel back to the pool only if the channel is healthy.private void
FixedChannelPool.tooManyOutstanding
(Promise<?> promise) Constructors in io.netty.channel.pool with parameters of type PromiseModifierConstructorDescription(package private)
AcquireListener
(Promise<Channel> originalPromise) (package private)
AcquireTask
(Promise<Channel> promise) -
Uses of Promise in io.netty.handler.codec.http2
Classes in io.netty.handler.codec.http2 that implement PromiseModifier and TypeClassDescription(package private) static final class
Provides the ability to associate the outcome of multipleChannelPromise
objects into a singleChannelPromise
object.Fields in io.netty.handler.codec.http2 declared as PromiseMethods in io.netty.handler.codec.http2 with parameters of type PromiseModifier and TypeMethodDescriptionClose this connection.Http2StreamChannelBootstrap.open
(Promise<Http2StreamChannel> promise) Open a newHttp2StreamChannel
to use and notifies the givenPromise
.void
Http2StreamChannelBootstrap.open0
(ChannelHandlerContext ctx, Promise<Http2StreamChannel> promise) Deprecated.should not be used directly. -
Uses of Promise in io.netty.handler.proxy
Classes in io.netty.handler.proxy that implement Promise -
Uses of Promise in io.netty.handler.ssl
Classes in io.netty.handler.ssl that implement PromiseFields in io.netty.handler.ssl declared as PromiseMethods in io.netty.handler.ssl with parameters of type PromiseModifier and TypeMethodDescriptionSniHandler.AsyncMappingAdapter.map
(String input, Promise<SslContext> promise) SslHandler.renegotiate
(Promise<Channel> promise) Performs TLS renegotiation.private void
SslHandler.renegotiateOnEventLoop
(Promise<Channel> newHandshakePromise) -
Uses of Promise in io.netty.handler.ssl.ocsp
Fields in io.netty.handler.ssl.ocsp declared as PromiseModifier and TypeFieldDescriptionprivate final Promise
<org.bouncycastle.cert.ocsp.OCSPResp> OcspHttpHandler.responseFuture
private final Promise
<org.bouncycastle.cert.ocsp.OCSPResp> OcspClient.Initializer.responsePromise
Methods in io.netty.handler.ssl.ocsp that return PromiseModifier and TypeMethodDescriptionprivate static Promise
<org.bouncycastle.cert.ocsp.OCSPResp> OcspClient.query
(EventLoop eventLoop, ByteBuf ocspRequest, String host, int port, String path, IoTransport ioTransport, DnsNameResolver dnsNameResolver) Query the OCSP responder for certificate status using HTTP/1.1(package private) static Promise
<org.bouncycastle.cert.ocsp.BasicOCSPResp> OcspClient.query
(X509Certificate x509Certificate, X509Certificate issuer, boolean validateResponseNonce, IoTransport ioTransport, DnsNameResolver dnsNameResolver) Query the certificate status using OCSPMethods in io.netty.handler.ssl.ocsp with parameters of type PromiseModifier and TypeMethodDescriptionprivate static void
OcspClient.validateResponse
(Promise<org.bouncycastle.cert.ocsp.BasicOCSPResp> responsePromise, org.bouncycastle.cert.ocsp.BasicOCSPResp basicResponse, org.bouncycastle.asn1.DEROctetString derNonce, X509Certificate issuer, boolean validateNonce) Constructors in io.netty.handler.ssl.ocsp with parameters of type PromiseModifierConstructorDescription(package private)
Initializer
(Promise<org.bouncycastle.cert.ocsp.OCSPResp> responsePromise) (package private)
OcspHttpHandler
(Promise<org.bouncycastle.cert.ocsp.OCSPResp> responsePromise) Create newOcspHttpHandler
instance -
Uses of Promise in io.netty.resolver
Methods in io.netty.resolver with parameters of type PromiseModifier and TypeMethodDescriptionprotected abstract void
Invoked byAbstractAddressResolver.resolve(SocketAddress)
to perform the actual name resolution.protected void
protected void
DefaultNameResolver.doResolve
(String inetHost, Promise<InetAddress> promise) protected void
InetSocketAddressResolver.doResolve
(InetSocketAddress unresolvedAddress, Promise<InetSocketAddress> promise) protected void
NoopAddressResolver.doResolve
(SocketAddress unresolvedAddress, Promise<SocketAddress> promise) protected void
RoundRobinInetAddressResolver.doResolve
(String inetHost, Promise<InetAddress> promise) protected abstract void
Invoked bySimpleNameResolver.resolve(String)
to perform the actual name resolution.protected abstract void
AbstractAddressResolver.doResolveAll
(T unresolvedAddress, Promise<List<T>> promise) Invoked byAbstractAddressResolver.resolveAll(SocketAddress)
to perform the actual name resolution.protected void
CompositeNameResolver.doResolveAll
(String inetHost, Promise<List<T>> promise) protected void
DefaultNameResolver.doResolveAll
(String inetHost, Promise<List<InetAddress>> promise) protected void
InetSocketAddressResolver.doResolveAll
(InetSocketAddress unresolvedAddress, Promise<List<InetSocketAddress>> promise) protected void
NoopAddressResolver.doResolveAll
(SocketAddress unresolvedAddress, Promise<List<SocketAddress>> promise) protected void
RoundRobinInetAddressResolver.doResolveAll
(String inetHost, Promise<List<InetAddress>> promise) protected abstract void
SimpleNameResolver.doResolveAll
(String inetHost, Promise<List<T>> promise) Invoked bySimpleNameResolver.resolveAll(String)
to perform the actual name resolution.private void
CompositeNameResolver.doResolveAllRec
(String inetHost, Promise<List<T>> promise, int resolverIndex, Throwable lastFailure) private void
CompositeNameResolver.doResolveRec
(String inetHost, Promise<T> promise, int resolverIndex, Throwable lastFailure) AbstractAddressResolver.resolve
(SocketAddress address, Promise<T> promise) AddressResolver.resolve
(SocketAddress address, Promise<T> promise) Resolves the specified address.Resolves the specified name into an address.AbstractAddressResolver.resolveAll
(SocketAddress address, Promise<List<T>> promise) AddressResolver.resolveAll
(SocketAddress address, Promise<List<T>> promise) Resolves the specified address.NameResolver.resolveAll
(String inetHost, Promise<List<T>> promise) Resolves the specified host name and port into a list of address.SimpleNameResolver.resolveAll
(String inetHost, Promise<List<T>> promise) -
Uses of Promise in io.netty.resolver.dns
Fields in io.netty.resolver.dns declared as PromiseModifier and TypeFieldDescriptionprivate final Promise
<?> DnsResolveContext.originalPromise
private final Promise
<AddressedEnvelope<DnsResponse, InetSocketAddress>> DnsQueryContext.promise
Fields in io.netty.resolver.dns with type parameters of type PromiseModifier and TypeFieldDescriptionprivate final ConcurrentMap
<String, Promise<List<InetAddress>>> DnsAddressResolverGroup.resolveAllsInProgress
private final ConcurrentMap
<String, Promise<List<T>>> InflightNameResolver.resolveAllsInProgress
private final ConcurrentMap
<String, Promise<InetAddress>> DnsAddressResolverGroup.resolvesInProgress
private final ConcurrentMap
<String, Promise<T>> InflightNameResolver.resolvesInProgress
Methods in io.netty.resolver.dns that return PromiseModifier and TypeMethodDescriptionprivate static Promise
<AddressedEnvelope<DnsResponse, InetSocketAddress>> private <U> Promise
<U> InflightNameResolver.resolve
(ConcurrentMap<String, Promise<U>> resolveMap, String inetHost, Promise<U> promise, boolean resolveAll) InflightNameResolver.resolveAll
(String inetHost, Promise<List<T>> promise) Methods in io.netty.resolver.dns with parameters of type PromiseModifier and TypeMethodDescriptionprivate static Promise
<AddressedEnvelope<DnsResponse, InetSocketAddress>> (package private) final Future
<AddressedEnvelope<DnsResponse, InetSocketAddress>> DnsNameResolver.doQuery
(Channel channel, InetSocketAddress nameServerAddr, DnsQuestion question, DnsQueryLifecycleObserver queryLifecycleObserver, DnsRecord[] additionals, boolean flush, Promise<AddressedEnvelope<? extends DnsResponse, InetSocketAddress>> promise) protected void
DnsNameResolver.doResolve
(String inetHost, DnsRecord[] additionals, Promise<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
(String inetHost, Promise<InetAddress> promise) protected void
DnsNameResolver.doResolveAll
(String inetHost, DnsRecord[] additionals, Promise<List<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
(String inetHost, Promise<List<InetAddress>> promise) (package private) static boolean
DnsNameResolver.doResolveAllCached
(String hostname, DnsRecord[] additionals, Promise<List<InetAddress>> promise, DnsCache resolveCache, String[] searchDomains, int ndots, InternetProtocolFamily[] resolvedInternetProtocolFamilies) private void
DnsNameResolver.doResolveAllNow
(ChannelFuture f, String hostname, DnsRecord[] additionals, Promise<List<InetAddress>> promise, DnsCache resolveCache) private void
DnsNameResolver.doResolveAllUncached
(Channel channel, String hostname, DnsRecord[] additionals, Promise<?> originalPromise, Promise<List<InetAddress>> promise, DnsCache resolveCache, boolean completeEarlyIfPossible) private void
DnsNameResolver.doResolveAllUncached0
(Channel channel, String hostname, DnsRecord[] additionals, Promise<?> originalPromise, Promise<List<InetAddress>> promise, DnsCache resolveCache, boolean completeEarlyIfPossible) private boolean
DnsNameResolver.doResolveCached
(String hostname, DnsRecord[] additionals, Promise<InetAddress> promise, DnsCache resolveCache) private void
DnsNameResolver.doResolveNow
(ChannelFuture f, String hostname, DnsRecord[] additionals, Promise<InetAddress> promise, DnsCache resolveCache) private void
DnsNameResolver.doResolveUncached
(Channel channel, String hostname, DnsRecord[] additionals, Promise<InetAddress> promise, DnsCache resolveCache, boolean completeEarlyIfPossible) (package private) void
DnsAddressResolveContext.doSearchDomainQuery
(String hostname, Promise<List<InetAddress>> nextPromise) (package private) void
DnsResolveContext.doSearchDomainQuery
(String hostname, Promise<List<T>> nextPromise) private void
DnsResolveContext.finishResolve
(Promise<List<T>> promise, Throwable cause) private void
DnsResolveContext.followCname
(DnsQuestion question, String cname, DnsQueryLifecycleObserver queryLifecycleObserver, Promise<List<T>> promise) private boolean
DnsResolveContext.handleRedirect
(DnsQuestion question, AddressedEnvelope<DnsResponse, InetSocketAddress> envelope, DnsQueryLifecycleObserver queryLifecycleObserver, Promise<List<T>> promise) Handles a redirect answer if needed and returnstrue
if a redirect query has been made.private void
DnsResolveContext.internalResolve
(String name, Promise<List<T>> promise) (package private) DnsResolveContext
<InetAddress> DnsAddressResolveContext.newResolverContext
(DnsNameResolver parent, Channel channel, Promise<?> originalPromise, String hostname, int dnsClass, DnsRecordType[] expectedTypes, DnsRecord[] additionals, DnsServerAddressStream nameServerAddrs, int allowedQueries) (package private) DnsResolveContext
<DnsRecord> DnsRecordResolveContext.newResolverContext
(DnsNameResolver parent, Channel channel, Promise<?> originalPromise, String hostname, int dnsClass, DnsRecordType[] expectedTypes, DnsRecord[] additionals, DnsServerAddressStream nameServerAddrs, int allowedQueries) (package private) abstract DnsResolveContext
<T> DnsResolveContext.newResolverContext
(DnsNameResolver parent, Channel channel, Promise<?> originalPromise, String hostname, int dnsClass, DnsRecordType[] expectedTypes, DnsRecord[] additionals, DnsServerAddressStream nameServerAddrs, int allowedQueries) Creates a new context with the given parameters.private void
DnsResolveContext.onExpectedResponse
(DnsQuestion question, AddressedEnvelope<DnsResponse, InetSocketAddress> envelope, DnsQueryLifecycleObserver queryLifecycleObserver, Promise<List<T>> promise) private void
DnsResolveContext.onResponse
(DnsServerAddressStream nameServerAddrStream, int nameServerAddrStreamIndex, DnsQuestion question, AddressedEnvelope<DnsResponse, InetSocketAddress> envelope, DnsQueryLifecycleObserver queryLifecycleObserver, Promise<List<T>> promise) private void
DnsResolveContext.onResponseCNAME
(DnsQuestion question, Map<String, String> cnames, DnsQueryLifecycleObserver queryLifecycleObserver, Promise<List<T>> promise) DnsNameResolver.query
(DnsQuestion question, Promise<AddressedEnvelope<? extends DnsResponse, InetSocketAddress>> promise) Sends a DNS query with the specified question.DnsNameResolver.query
(InetSocketAddress nameServerAddr, DnsQuestion question, Promise<AddressedEnvelope<? extends DnsResponse, InetSocketAddress>> promise) Sends a DNS query with the specified question using the specified name server list.DnsNameResolver.query
(InetSocketAddress nameServerAddr, DnsQuestion question, Iterable<DnsRecord> additionals, Promise<AddressedEnvelope<? extends DnsResponse, InetSocketAddress>> promise) Sends a DNS query with the specified question with additional records using the specified name server list.private void
DnsResolveContext.query
(DnsServerAddressStream nameServerAddrStream, int nameServerAddrStreamIndex, DnsQuestion question, DnsQueryLifecycleObserver queryLifecycleObserver, boolean flush, Promise<List<T>> promise, Throwable cause) private boolean
DnsResolveContext.query
(String hostname, DnsRecordType type, DnsServerAddressStream dnsServerAddressStream, boolean flush, Promise<List<T>> promise) private void
DnsResolveContext.queryUnresolvedNameServer
(InetSocketAddress nameServerAddr, DnsServerAddressStream nameServerAddrStream, int nameServerAddrStreamIndex, DnsQuestion question, DnsQueryLifecycleObserver queryLifecycleObserver, Promise<List<T>> promise, Throwable cause) final Future
<InetAddress> DnsNameResolver.resolve
(String inetHost, Iterable<DnsRecord> additionals, Promise<InetAddress> promise) Resolves the specified name into an address.(package private) void
private <U> Promise
<U> InflightNameResolver.resolve
(ConcurrentMap<String, Promise<U>> resolveMap, String inetHost, Promise<U> promise, boolean resolveAll) DnsNameResolver.resolveAll
(DnsQuestion question, DnsRecord[] additionals, Promise<List<DnsRecord>> promise) DnsNameResolver.resolveAll
(DnsQuestion question, Iterable<DnsRecord> additionals, Promise<List<DnsRecord>> promise) Resolves theDnsRecord
s that are matched by the specifiedDnsQuestion
.final Future
<List<InetAddress>> DnsNameResolver.resolveAll
(String inetHost, Iterable<DnsRecord> additionals, Promise<List<InetAddress>> promise) Resolves the specified host name and port into a list of address.InflightNameResolver.resolveAll
(String inetHost, Promise<List<T>> promise) private void
DnsNameResolver.resolveAllNow
(ChannelFuture f, String hostname, DnsQuestion question, DnsRecord[] additionals, Promise<List<DnsRecord>> promise) private void
DnsNameResolver.resolveNow
(Channel channel, String hostname, DnsRecord[] additionals, Promise<?> originalPromise, Promise<List<InetAddress>> promise, DnsCache resolveCache, boolean completeEarlyIfPossible) private static <T> void
InflightNameResolver.transferResult
(Future<T> src, Promise<T> dst) private static void
DnsNameResolver.tryFailure
(Promise<?> promise, Throwable cause) (package private) static <T> boolean
DnsNameResolver.trySuccess
(Promise<T> promise, T result) private void
DnsResolveContext.tryToFinishResolve
(DnsServerAddressStream nameServerAddrStream, int nameServerAddrStreamIndex, DnsQuestion question, DnsQueryLifecycleObserver queryLifecycleObserver, Promise<List<T>> promise, Throwable cause) Method parameters in io.netty.resolver.dns with type arguments of type PromiseModifier and TypeMethodDescriptionprivate <U> Promise
<U> InflightNameResolver.resolve
(ConcurrentMap<String, Promise<U>> resolveMap, String inetHost, Promise<U> promise, boolean resolveAll) Constructors in io.netty.resolver.dns with parameters of type PromiseModifierConstructorDescription(package private)
DatagramDnsQueryContext
(Channel channel, InetSocketAddress nameServerAddr, DnsQueryContextManager queryContextManager, int maxPayLoadSize, boolean recursionDesired, long queryTimeoutMillis, DnsQuestion question, DnsRecord[] additionals, Promise<AddressedEnvelope<DnsResponse, InetSocketAddress>> promise, Bootstrap socketBootstrap, boolean retryWithTcpOnTimeout) (package private)
DnsAddressResolveContext
(DnsNameResolver parent, Channel channel, Promise<?> originalPromise, String hostname, DnsRecord[] additionals, DnsServerAddressStream nameServerAddrs, int allowedQueries, DnsCache resolveCache, AuthoritativeDnsServerCache authoritativeDnsServerCache, boolean completeEarlyIfPossible) (package private)
DnsQueryContext
(Channel channel, InetSocketAddress nameServerAddr, DnsQueryContextManager queryContextManager, int maxPayLoadSize, boolean recursionDesired, long queryTimeoutMillis, DnsQuestion question, DnsRecord[] additionals, Promise<AddressedEnvelope<DnsResponse, InetSocketAddress>> promise, Bootstrap socketBootstrap, boolean retryWithTcpOnTimeout) (package private)
DnsRecordResolveContext
(DnsNameResolver parent, Channel channel, Promise<?> originalPromise, DnsQuestion question, DnsRecord[] additionals, DnsServerAddressStream nameServerAddrs, int allowedQueries) private
DnsRecordResolveContext
(DnsNameResolver parent, Channel channel, Promise<?> originalPromise, String hostname, int dnsClass, DnsRecordType[] expectedTypes, DnsRecord[] additionals, DnsServerAddressStream nameServerAddrs, int allowedQueries) (package private)
DnsResolveContext
(DnsNameResolver parent, Channel channel, Promise<?> originalPromise, String hostname, int dnsClass, DnsRecordType[] expectedTypes, DnsRecord[] additionals, DnsServerAddressStream nameServerAddrs, int allowedQueries) (package private)
TcpDnsQueryContext
(Channel channel, InetSocketAddress nameServerAddr, DnsQueryContextManager queryContextManager, int maxPayLoadSize, boolean recursionDesired, long queryTimeoutMillis, DnsQuestion question, DnsRecord[] additionals, Promise<AddressedEnvelope<DnsResponse, InetSocketAddress>> promise) Constructor parameters in io.netty.resolver.dns with type arguments of type PromiseModifierConstructorDescription(package private)
InflightNameResolver
(EventExecutor executor, NameResolver<T> delegate, ConcurrentMap<String, Promise<T>> resolvesInProgress, ConcurrentMap<String, Promise<List<T>>> resolveAllsInProgress) -
Uses of Promise in io.netty.util
Methods in io.netty.util with parameters of type Promise -
Uses of Promise in io.netty.util.concurrent
Subinterfaces of Promise in io.netty.util.concurrentClasses in io.netty.util.concurrent that implement PromiseModifier and TypeClassDescriptionclass
class
(package private) static class
(package private) static class
(package private) class
PromiseTask<V>
(package private) final class
private static final class
Fields in io.netty.util.concurrent declared as PromiseModifier and TypeFieldDescriptionprivate final Promise
<?> PromiseAggregator.aggregatePromise
Deprecated.PromiseCombiner.aggregatePromise
UnaryPromiseNotifier.promise
Deprecated.PromiseNotifier.promises
private final Promise
<?> MultithreadEventExecutorGroup.terminationFuture
private final Promise
<?> SingleThreadEventExecutor.terminationFuture
private final Promise
<?> UnorderedThreadPoolEventExecutor.terminationFuture
Fields in io.netty.util.concurrent with type parameters of type PromiseMethods in io.netty.util.concurrent that return PromiseModifier and TypeMethodDescriptionDefaultPromise.addListener
(GenericFutureListener<? extends Future<? super V>> listener) Promise.addListener
(GenericFutureListener<? extends Future<? super V>> listener) DefaultPromise.addListeners
(GenericFutureListener<? extends Future<? super V>>... listeners) Promise.addListeners
(GenericFutureListener<? extends Future<? super V>>... listeners) DefaultPromise.await()
Promise.await()
DefaultPromise.awaitUninterruptibly()
Promise.awaitUninterruptibly()
<V> Promise
<V> AbstractEventExecutor.newPromise()
<V> Promise
<V> EventExecutor.newPromise()
Return a newPromise
.<V> Promise
<V> ImmediateEventExecutor.newPromise()
<V> Promise
<V> UnorderedThreadPoolEventExecutor.newPromise()
DefaultPromise.removeListener
(GenericFutureListener<? extends Future<? super V>> listener) Promise.removeListener
(GenericFutureListener<? extends Future<? super V>> listener) DefaultPromise.removeListeners
(GenericFutureListener<? extends Future<? super V>>... listeners) Promise.removeListeners
(GenericFutureListener<? extends Future<? super V>>... listeners) DefaultPromise.setFailure
(Throwable cause) Promise.setFailure
(Throwable cause) Marks this future as a failure and notifies all listeners.PromiseTask.setFailure
(Throwable cause) PromiseTask.setFailureInternal
(Throwable cause) DefaultPromise.setSuccess
(V result) Promise.setSuccess
(V result) Marks this future as a success and notifies all listeners.PromiseTask.setSuccess
(V result) PromiseTask.setSuccessInternal
(V result) DefaultPromise.sync()
Promise.sync()
DefaultPromise.syncUninterruptibly()
Promise.syncUninterruptibly()
Methods in io.netty.util.concurrent with parameters of type PromiseModifier and TypeMethodDescriptionfinal PromiseAggregator
<V, F> Deprecated.Add the givenPromise
s to the aggregator.void
Deprecated.Replaced byPromiseCombiner.add(Future)
.void
Deprecated.Replaced byPromiseCombiner.addAll(Future[])
static <V,
F extends Future<V>>
Fstatic <V,
F extends Future<V>>
Fstatic <X> void
Deprecated.void
Sets the promise to be notified when all combined futures have finished.Constructors in io.netty.util.concurrent with parameters of type PromiseModifierConstructorDescriptionPromiseAggregator
(Promise<Void> aggregatePromise) Deprecated.PromiseAggregator
(Promise<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) Deprecated. -
Uses of Promise in io.netty.util.internal
Fields in io.netty.util.internal declared as PromiseMethods in io.netty.util.internal that return PromiseModifier and TypeMethodDescriptionPendingWrite.promise()
PendingWrite.recycleAndGet()
Recycle this instance and return thePromise
.Methods in io.netty.util.internal with parameters of type PromiseModifier and TypeMethodDescriptionstatic PendingWrite
PendingWrite.newInstance
(Object msg, Promise<Void> promise) Create a new emptyRecyclableArrayList
instancestatic void
PromiseNotificationUtil.tryCancel
(Promise<?> p, InternalLogger logger) static void
PromiseNotificationUtil.tryFailure
(Promise<?> p, Throwable cause, InternalLogger logger) static <V> void
PromiseNotificationUtil.trySuccess
(Promise<? super V> p, V result, InternalLogger logger)