Uses of Interface
io.netty.util.concurrent.Promise
-
Packages that use Promise 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 openChannel
s and perform bulk operations on them.io.netty.channel.pool Implementations and API forChannel
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 tunnelingio.netty.handler.ssl SSL · TLS implementation based onSSLEngine
io.netty.handler.ssl.ocsp OCSP stapling, formally known as the TLS Certificate Status Request extension, is an alternative approach to the Online Certificate Status Protocol (OCSP) for checking the revocation status of X.509 digital certificates.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. -
-
Uses of Promise in io.netty.bootstrap
Classes in io.netty.bootstrap that implement Promise Modifier and Type Class Description (package private) static class
AbstractBootstrap.PendingRegistrationPromise
-
Uses of Promise in io.netty.channel
Subinterfaces of Promise in io.netty.channel Modifier and Type Interface Description interface
ChannelProgressivePromise
SpecialChannelPromise
which will be notified once the associated bytes is transferring.interface
ChannelPromise
SpecialChannelFuture
which is writable.Classes in io.netty.channel that implement Promise Modifier and Type Class Description (package private) static class
AbstractChannel.CloseFuture
class
DefaultChannelProgressivePromise
The defaultChannelProgressivePromise
implementation.class
DefaultChannelPromise
The defaultChannelPromise
implementation.class
DelegatingChannelPromiseNotifier
class
VoidChannelPromise
Fields in io.netty.channel declared as Promise Modifier and Type Field Description private Promise<?>
ThreadPerChannelEventLoopGroup. terminationFuture
Deprecated. -
Uses of Promise in io.netty.channel.group
Classes in io.netty.channel.group that implement Promise Modifier and Type Class Description (package private) class
DefaultChannelGroupFuture
The defaultChannelGroupFuture
implementation. -
Uses of Promise in io.netty.channel.pool
Fields in io.netty.channel.pool declared as Promise Modifier and Type Field Description private Promise<Channel>
FixedChannelPool.AcquireListener. originalPromise
(package private) Promise<Channel>
FixedChannelPool.AcquireTask. promise
Methods in io.netty.channel.pool with parameters of type Promise Modifier and Type Method Description Future<Channel>
ChannelPool. acquire(Promise<Channel> promise)
Acquire aChannel
from thisChannelPool
.Future<Channel>
FixedChannelPool. acquire(Promise<Channel> promise)
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 void
SimpleChannelPool. closeAndFail(Channel channel, java.lang.Throwable cause, Promise<?> promise)
private void
SimpleChannelPool. doHealthCheck(Channel channel, 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 channel, Promise<Channel> promise)
Future<java.lang.Void>
ChannelPool. release(Channel channel, Promise<java.lang.Void> promise)
Release aChannel
back to thisChannelPool
.Future<java.lang.Void>
FixedChannelPool. release(Channel channel, Promise<java.lang.Void> promise)
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.private void
FixedChannelPool. tooManyOutstanding(Promise<?> promise)
Constructors in io.netty.channel.pool with parameters of type Promise Constructor Description AcquireListener(Promise<Channel> originalPromise)
AcquireTask(Promise<Channel> promise)
-
Uses of Promise in io.netty.handler.codec.http2
Classes in io.netty.handler.codec.http2 that implement Promise Modifier and Type Class Description (package private) static class
Http2CodecUtil.SimpleChannelPromiseAggregator
Provides the ability to associate the outcome of multipleChannelPromise
objects into a singleChannelPromise
object.Fields in io.netty.handler.codec.http2 declared as Promise Modifier and Type Field Description (package private) Promise<java.lang.Void>
DefaultHttp2Connection. closePromise
Methods in io.netty.handler.codec.http2 with parameters of type Promise Modifier and Type Method 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.Future<Http2StreamChannel>
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 Modifier and Type Class Description private class
ProxyHandler.LazyChannelPromise
-
Uses of Promise in io.netty.handler.ssl
Classes in io.netty.handler.ssl that implement Promise Modifier and Type Class Description private class
SslHandler.LazyChannelPromise
Fields in io.netty.handler.ssl declared as Promise Modifier and Type Field Description private Promise<Channel>
SslHandler. handshakePromise
Methods in io.netty.handler.ssl with parameters of type Promise Modifier and Type Method Description Future<SslContext>
SniHandler.AsyncMappingAdapter. map(java.lang.String input, Promise<SslContext> promise)
Future<Channel>
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 Promise Modifier and Type Field Description private Promise<org.bouncycastle.cert.ocsp.OCSPResp>
OcspHttpHandler. responseFuture
private Promise<org.bouncycastle.cert.ocsp.OCSPResp>
OcspClient.Initializer. responsePromise
Methods in io.netty.handler.ssl.ocsp that return Promise Modifier and Type Method Description private static Promise<org.bouncycastle.cert.ocsp.OCSPResp>
OcspClient. query(EventLoop eventLoop, ByteBuf ocspRequest, java.lang.String host, int port, java.lang.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(java.security.cert.X509Certificate x509Certificate, java.security.cert.X509Certificate issuer, boolean validateResponseNonce, IoTransport ioTransport, DnsNameResolver dnsNameResolver)
Query the certificate status using OCSPMethods in io.netty.handler.ssl.ocsp with parameters of type Promise Modifier and Type Method Description private static void
OcspClient. validateResponse(Promise<org.bouncycastle.cert.ocsp.BasicOCSPResp> responsePromise, org.bouncycastle.cert.ocsp.BasicOCSPResp basicResponse, org.bouncycastle.asn1.DEROctetString derNonce, java.security.cert.X509Certificate issuer, boolean validateNonce)
Constructors in io.netty.handler.ssl.ocsp with parameters of type Promise Constructor Description Initializer(Promise<org.bouncycastle.cert.ocsp.OCSPResp> responsePromise)
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 Promise Modifier and Type Method Description protected abstract void
AbstractAddressResolver. doResolve(T unresolvedAddress, Promise<T> promise)
Invoked byAbstractAddressResolver.resolve(SocketAddress)
to perform the actual name resolution.protected void
CompositeNameResolver. doResolve(java.lang.String inetHost, Promise<T> promise)
protected void
DefaultNameResolver. doResolve(java.lang.String inetHost, Promise<java.net.InetAddress> promise)
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 abstract void
SimpleNameResolver. doResolve(java.lang.String inetHost, Promise<T> promise)
Invoked bySimpleNameResolver.resolve(String)
to perform the actual name resolution.protected abstract void
AbstractAddressResolver. doResolveAll(T unresolvedAddress, Promise<java.util.List<T>> promise)
Invoked byAbstractAddressResolver.resolveAll(SocketAddress)
to perform the actual name resolution.protected void
CompositeNameResolver. doResolveAll(java.lang.String inetHost, Promise<java.util.List<T>> promise)
protected void
DefaultNameResolver. doResolveAll(java.lang.String inetHost, Promise<java.util.List<java.net.InetAddress>> promise)
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 abstract void
SimpleNameResolver. doResolveAll(java.lang.String inetHost, Promise<java.util.List<T>> promise)
Invoked bySimpleNameResolver.resolveAll(String)
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>
AbstractAddressResolver. resolve(java.net.SocketAddress address, Promise<T> promise)
Future<T>
AddressResolver. resolve(java.net.SocketAddress address, Promise<T> promise)
Resolves the specified address.Future<T>
NameResolver. resolve(java.lang.String inetHost, Promise<T> promise)
Resolves the specified name into an address.Future<T>
SimpleNameResolver. resolve(java.lang.String inetHost, Promise<T> promise)
Future<java.util.List<T>>
AbstractAddressResolver. resolveAll(java.net.SocketAddress address, Promise<java.util.List<T>> promise)
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>>
NameResolver. resolveAll(java.lang.String inetHost, Promise<java.util.List<T>> promise)
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)
-
Uses of Promise in io.netty.resolver.dns
Fields in io.netty.resolver.dns declared as Promise Modifier and Type Field Description private Promise<?>
DnsResolveContext. originalPromise
private Promise<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>>
DnsQueryContext. promise
Fields in io.netty.resolver.dns with type parameters of type Promise Modifier and Type Field Description 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<java.util.List<T>>>
InflightNameResolver. resolveAllsInProgress
private java.util.concurrent.ConcurrentMap<java.lang.String,Promise<java.net.InetAddress>>
DnsAddressResolverGroup. resolvesInProgress
private java.util.concurrent.ConcurrentMap<java.lang.String,Promise<T>>
InflightNameResolver. resolvesInProgress
Methods in io.netty.resolver.dns that return Promise Modifier and Type Method Description private static Promise<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>>
DnsNameResolver. cast(Promise<?> promise)
Promise<T>
InflightNameResolver. resolve(java.lang.String inetHost, Promise<T> 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<java.util.List<T>>
InflightNameResolver. resolveAll(java.lang.String inetHost, Promise<java.util.List<T>> promise)
Methods in io.netty.resolver.dns with parameters of type Promise Modifier and Type Method Description private static Promise<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>>
DnsNameResolver. cast(Promise<?> promise)
(package private) Future<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>>
DnsNameResolver. doQuery(Channel channel, java.net.InetSocketAddress nameServerAddr, DnsQuestion question, DnsQueryLifecycleObserver queryLifecycleObserver, DnsRecord[] additionals, boolean flush, Promise<AddressedEnvelope<? extends DnsResponse,java.net.InetSocketAddress>> 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)
(package private) static boolean
DnsNameResolver. doResolveAllCached(java.lang.String hostname, DnsRecord[] additionals, Promise<java.util.List<java.net.InetAddress>> promise, DnsCache resolveCache, java.lang.String[] searchDomains, int ndots, InternetProtocolFamily[] resolvedInternetProtocolFamilies)
private void
DnsNameResolver. doResolveAllNow(ChannelFuture f, java.lang.String hostname, DnsRecord[] additionals, Promise<java.util.List<java.net.InetAddress>> promise, DnsCache resolveCache)
private void
DnsNameResolver. doResolveAllUncached(Channel channel, java.lang.String hostname, DnsRecord[] additionals, Promise<?> originalPromise, Promise<java.util.List<java.net.InetAddress>> promise, DnsCache resolveCache, boolean completeEarlyIfPossible)
private void
DnsNameResolver. doResolveAllUncached0(Channel channel, java.lang.String hostname, DnsRecord[] additionals, Promise<?> originalPromise, Promise<java.util.List<java.net.InetAddress>> promise, DnsCache resolveCache, boolean completeEarlyIfPossible)
private boolean
DnsNameResolver. doResolveCached(java.lang.String hostname, DnsRecord[] additionals, Promise<java.net.InetAddress> promise, DnsCache resolveCache)
private void
DnsNameResolver. doResolveNow(ChannelFuture f, java.lang.String hostname, DnsRecord[] additionals, Promise<java.net.InetAddress> promise, DnsCache resolveCache)
private void
DnsNameResolver. doResolveUncached(Channel channel, java.lang.String hostname, DnsRecord[] additionals, Promise<java.net.InetAddress> promise, DnsCache resolveCache, boolean completeEarlyIfPossible)
(package private) void
DnsAddressResolveContext. doSearchDomainQuery(java.lang.String hostname, Promise<java.util.List<java.net.InetAddress>> nextPromise)
(package private) void
DnsResolveContext. doSearchDomainQuery(java.lang.String hostname, Promise<java.util.List<T>> nextPromise)
private void
DnsResolveContext. finishResolve(Promise<java.util.List<T>> promise, java.lang.Throwable cause)
private void
DnsResolveContext. followCname(DnsQuestion question, java.lang.String cname, DnsQueryLifecycleObserver queryLifecycleObserver, Promise<java.util.List<T>> promise)
private boolean
DnsResolveContext. handleRedirect(DnsQuestion question, AddressedEnvelope<DnsResponse,java.net.InetSocketAddress> envelope, DnsQueryLifecycleObserver queryLifecycleObserver, Promise<java.util.List<T>> promise)
Handles a redirect answer if needed and returnstrue
if a redirect query has been made.private void
DnsResolveContext. internalResolve(java.lang.String name, Promise<java.util.List<T>> promise)
(package private) DnsResolveContext<java.net.InetAddress>
DnsAddressResolveContext. newResolverContext(DnsNameResolver parent, Channel channel, Promise<?> originalPromise, java.lang.String hostname, int dnsClass, DnsRecordType[] expectedTypes, DnsRecord[] additionals, DnsServerAddressStream nameServerAddrs, int allowedQueries)
(package private) DnsResolveContext<DnsRecord>
DnsRecordResolveContext. newResolverContext(DnsNameResolver parent, Channel channel, Promise<?> originalPromise, java.lang.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, java.lang.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,java.net.InetSocketAddress> envelope, DnsQueryLifecycleObserver queryLifecycleObserver, Promise<java.util.List<T>> promise)
private void
DnsResolveContext. onResponse(DnsServerAddressStream nameServerAddrStream, int nameServerAddrStreamIndex, DnsQuestion question, AddressedEnvelope<DnsResponse,java.net.InetSocketAddress> envelope, DnsQueryLifecycleObserver queryLifecycleObserver, Promise<java.util.List<T>> promise)
private void
DnsResolveContext. onResponseCNAME(DnsQuestion question, java.util.Map<java.lang.String,java.lang.String> cnames, DnsQueryLifecycleObserver queryLifecycleObserver, Promise<java.util.List<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.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.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.private void
DnsResolveContext. query(DnsServerAddressStream nameServerAddrStream, int nameServerAddrStreamIndex, DnsQuestion question, DnsQueryLifecycleObserver queryLifecycleObserver, boolean flush, Promise<java.util.List<T>> promise, java.lang.Throwable cause)
private boolean
DnsResolveContext. query(java.lang.String hostname, DnsRecordType type, DnsServerAddressStream dnsServerAddressStream, boolean flush, Promise<java.util.List<T>> promise)
private void
DnsResolveContext. queryUnresolvedNameServer(java.net.InetSocketAddress nameServerAddr, DnsServerAddressStream nameServerAddrStream, int nameServerAddrStreamIndex, DnsQuestion question, DnsQueryLifecycleObserver queryLifecycleObserver, Promise<java.util.List<T>> promise, java.lang.Throwable cause)
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.(package private) void
DnsResolveContext. resolve(Promise<java.util.List<T>> promise)
Promise<T>
InflightNameResolver. resolve(java.lang.String inetHost, Promise<T> 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)
private Future<java.util.List<DnsRecord>>
DnsNameResolver. resolveAll(DnsQuestion question, DnsRecord[] additionals, Promise<java.util.List<DnsRecord>> promise)
Future<java.util.List<DnsRecord>>
DnsNameResolver. resolveAll(DnsQuestion question, java.lang.Iterable<DnsRecord> additionals, Promise<java.util.List<DnsRecord>> promise)
Resolves theDnsRecord
s that are matched by the specifiedDnsQuestion
.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 void
DnsNameResolver. resolveAllNow(ChannelFuture f, java.lang.String hostname, DnsQuestion question, DnsRecord[] additionals, Promise<java.util.List<DnsRecord>> promise)
private void
DnsNameResolver. resolveNow(Channel channel, java.lang.String hostname, DnsRecord[] additionals, Promise<?> originalPromise, Promise<java.util.List<java.net.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, java.lang.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<java.util.List<T>> promise, java.lang.Throwable cause)
Method parameters in io.netty.resolver.dns with type arguments of type Promise Modifier and Type Method 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)
Constructors in io.netty.resolver.dns with parameters of type Promise Constructor Description DatagramDnsQueryContext(Channel channel, java.net.InetSocketAddress nameServerAddr, DnsQueryContextManager queryContextManager, int maxPayLoadSize, boolean recursionDesired, long queryTimeoutMillis, DnsQuestion question, DnsRecord[] additionals, Promise<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>> promise, Bootstrap socketBootstrap, boolean retryWithTcpOnTimeout)
DnsAddressResolveContext(DnsNameResolver parent, Channel channel, Promise<?> originalPromise, java.lang.String hostname, DnsRecord[] additionals, DnsServerAddressStream nameServerAddrs, int allowedQueries, DnsCache resolveCache, AuthoritativeDnsServerCache authoritativeDnsServerCache, boolean completeEarlyIfPossible)
DnsQueryContext(Channel channel, java.net.InetSocketAddress nameServerAddr, DnsQueryContextManager queryContextManager, int maxPayLoadSize, boolean recursionDesired, long queryTimeoutMillis, DnsQuestion question, DnsRecord[] additionals, Promise<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>> promise, Bootstrap socketBootstrap, boolean retryWithTcpOnTimeout)
DnsRecordResolveContext(DnsNameResolver parent, Channel channel, Promise<?> originalPromise, DnsQuestion question, DnsRecord[] additionals, DnsServerAddressStream nameServerAddrs, int allowedQueries)
DnsRecordResolveContext(DnsNameResolver parent, Channel channel, Promise<?> originalPromise, java.lang.String hostname, int dnsClass, DnsRecordType[] expectedTypes, DnsRecord[] additionals, DnsServerAddressStream nameServerAddrs, int allowedQueries)
DnsResolveContext(DnsNameResolver parent, Channel channel, Promise<?> originalPromise, java.lang.String hostname, int dnsClass, DnsRecordType[] expectedTypes, DnsRecord[] additionals, DnsServerAddressStream nameServerAddrs, int allowedQueries)
TcpDnsQueryContext(Channel channel, java.net.InetSocketAddress nameServerAddr, DnsQueryContextManager queryContextManager, int maxPayLoadSize, boolean recursionDesired, long queryTimeoutMillis, DnsQuestion question, DnsRecord[] additionals, Promise<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>> promise)
Constructor parameters in io.netty.resolver.dns with type arguments of type Promise Constructor 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)
-
Uses of Promise in io.netty.util
Methods in io.netty.util with parameters of type Promise Modifier and Type Method Description Future<OUT>
AsyncMapping. map(IN input, Promise<OUT> promise)
Returns theFuture
that will provide the result of the mapping. -
Uses of Promise in io.netty.util.concurrent
Subinterfaces of Promise in io.netty.util.concurrent Modifier and Type Interface Description interface
ProgressivePromise<V>
SpecialProgressiveFuture
which is writable.Classes in io.netty.util.concurrent that implement Promise Modifier and Type Class 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>
Fields in io.netty.util.concurrent declared as Promise Modifier and Type Field Description private Promise<?>
PromiseAggregator. aggregatePromise
Deprecated.private Promise<java.lang.Void>
PromiseCombiner. aggregatePromise
private Promise<? super T>
UnaryPromiseNotifier. promise
Deprecated.private Promise<? super V>[]
PromiseNotifier. promises
private Promise<?>
MultithreadEventExecutorGroup. terminationFuture
private Promise<?>
SingleThreadEventExecutor. terminationFuture
private Promise<?>
UnorderedThreadPoolEventExecutor. terminationFuture
Fields in io.netty.util.concurrent with type parameters of type Promise Modifier and Type Field Description private java.util.Set<Promise<V>>
PromiseAggregator. pendingPromises
Deprecated.Methods in io.netty.util.concurrent that return Promise Modifier and Type Method Description Promise<V>
DefaultPromise. addListener(GenericFutureListener<? extends Future<? super V>> listener)
Promise<V>
Promise. addListener(GenericFutureListener<? extends Future<? super V>> listener)
Promise<V>
DefaultPromise. addListeners(GenericFutureListener<? extends Future<? super V>>... listeners)
Promise<V>
Promise. addListeners(GenericFutureListener<? extends Future<? super V>>... listeners)
Promise<V>
DefaultPromise. await()
Promise<V>
Promise. await()
Promise<V>
DefaultPromise. awaitUninterruptibly()
Promise<V>
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()
Promise<V>
DefaultPromise. removeListener(GenericFutureListener<? extends Future<? super V>> listener)
Promise<V>
Promise. removeListener(GenericFutureListener<? extends Future<? super V>> listener)
Promise<V>
DefaultPromise. removeListeners(GenericFutureListener<? extends Future<? super V>>... listeners)
Promise<V>
Promise. removeListeners(GenericFutureListener<? extends Future<? super V>>... listeners)
Promise<V>
DefaultPromise. setFailure(java.lang.Throwable cause)
Promise<V>
Promise. setFailure(java.lang.Throwable cause)
Marks this future as a failure and notifies all listeners.Promise<V>
PromiseTask. setFailure(java.lang.Throwable cause)
protected Promise<V>
PromiseTask. setFailureInternal(java.lang.Throwable cause)
Promise<V>
DefaultPromise. setSuccess(V result)
Promise<V>
Promise. setSuccess(V result)
Marks this future as a success and notifies all listeners.Promise<V>
PromiseTask. setSuccess(V result)
protected Promise<V>
PromiseTask. setSuccessInternal(V result)
Promise<V>
DefaultPromise. sync()
Promise<V>
Promise. sync()
Promise<V>
DefaultPromise. syncUninterruptibly()
Promise<V>
Promise. syncUninterruptibly()
Methods in io.netty.util.concurrent with parameters of type Promise Modifier and Type Method Description PromiseAggregator<V,F>
PromiseAggregator. add(Promise<V>... promises)
Deprecated.Add the givenPromise
s to the aggregator.void
PromiseCombiner. add(Promise promise)
Deprecated.Replaced byPromiseCombiner.add(Future)
.void
PromiseCombiner. addAll(Promise... promises)
Deprecated.Replaced byPromiseCombiner.addAll(Future[])
static <V,F extends Future<V>>
FPromiseNotifier. cascade(boolean logNotifyFailure, F future, Promise<? super V> promise)
static <V,F extends Future<V>>
FPromiseNotifier. cascade(F future, Promise<? super V> promise)
static <X> void
UnaryPromiseNotifier. cascadeTo(Future<X> completedFuture, Promise<? super X> promise)
Deprecated.void
PromiseCombiner. finish(Promise<java.lang.Void> aggregatePromise)
Sets the promise to be notified when all combined futures have finished.Constructors in io.netty.util.concurrent with parameters of type Promise Constructor 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)
Deprecated. -
Uses of Promise in io.netty.util.internal
Fields in io.netty.util.internal declared as Promise Modifier and Type Field Description private Promise<java.lang.Void>
PendingWrite. promise
Methods in io.netty.util.internal that return Promise Modifier and Type Method Description Promise<java.lang.Void>
PendingWrite. promise()
Promise<java.lang.Void>
PendingWrite. recycleAndGet()
Recycle this instance and return thePromise
.Methods in io.netty.util.internal with parameters of type Promise Modifier and Type Method Description static PendingWrite
PendingWrite. newInstance(java.lang.Object msg, Promise<java.lang.Void> promise)
Create a new emptyRecyclableArrayList
instancestatic 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)
-