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 openChannels and perform bulk operations on them.io.netty.channel.pool Implementations and API forChannelpools.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 onSSLEngineio.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 classAbstractBootstrap.PendingRegistrationPromise -
Uses of Promise in io.netty.channel
Subinterfaces of Promise in io.netty.channel Modifier and Type Interface Description interfaceChannelProgressivePromiseSpecialChannelPromisewhich will be notified once the associated bytes is transferring.interfaceChannelPromiseSpecialChannelFuturewhich is writable.Classes in io.netty.channel that implement Promise Modifier and Type Class Description (package private) static classAbstractChannel.CloseFutureclassDefaultChannelProgressivePromiseThe defaultChannelProgressivePromiseimplementation.classDefaultChannelPromiseThe defaultChannelPromiseimplementation.classDelegatingChannelPromiseNotifierclassVoidChannelPromiseFields in io.netty.channel declared as Promise Modifier and Type Field Description private Promise<?>ThreadPerChannelEventLoopGroup. terminationFutureDeprecated. -
Uses of Promise in io.netty.channel.group
Classes in io.netty.channel.group that implement Promise Modifier and Type Class Description (package private) classDefaultChannelGroupFutureThe defaultChannelGroupFutureimplementation. -
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. promiseMethods in io.netty.channel.pool with parameters of type Promise Modifier and Type Method Description Future<Channel>ChannelPool. acquire(Promise<Channel> promise)Acquire aChannelfrom thisChannelPool.Future<Channel>FixedChannelPool. acquire(Promise<Channel> promise)Future<Channel>SimpleChannelPool. acquire(Promise<Channel> promise)private voidFixedChannelPool. 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 voidSimpleChannelPool. closeAndFail(Channel channel, java.lang.Throwable cause, Promise<?> promise)private voidSimpleChannelPool. doHealthCheck(Channel ch, Promise<Channel> promise)private voidSimpleChannelPool. doHealthCheckOnRelease(Channel channel, Promise<java.lang.Void> promise)private voidSimpleChannelPool. doReleaseChannel(Channel channel, Promise<java.lang.Void> promise)private voidSimpleChannelPool. notifyConnect(ChannelFuture future, Promise<Channel> promise)private voidSimpleChannelPool. notifyHealthCheck(Future<java.lang.Boolean> future, Channel ch, Promise<Channel> promise)Future<java.lang.Void>ChannelPool. release(Channel channel, Promise<java.lang.Void> promise)Release aChannelback 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 voidSimpleChannelPool. releaseAndOffer(Channel channel, Promise<java.lang.Void> promise)private voidSimpleChannelPool. 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 voidFixedChannelPool. 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 classHttp2CodecUtil.SimpleChannelPromiseAggregatorProvides the ability to associate the outcome of multipleChannelPromiseobjects into a singleChannelPromiseobject.Fields in io.netty.handler.codec.http2 declared as Promise Modifier and Type Field Description (package private) Promise<java.lang.Void>DefaultHttp2Connection. closePromiseMethods 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 newHttp2StreamChannelto use and notifies the givenPromise.voidHttp2StreamChannelBootstrap. 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 classProxyHandler.LazyChannelPromise -
Uses of Promise in io.netty.handler.ssl
Classes in io.netty.handler.ssl that implement Promise Modifier and Type Class Description private classSslHandler.LazyChannelPromiseFields in io.netty.handler.ssl declared as Promise Modifier and Type Field Description private Promise<Channel>SslHandler. handshakePromiseMethods 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 voidSslHandler. renegotiateOnEventLoop(Promise<Channel> newHandshakePromise) -
Uses of Promise in io.netty.resolver
Methods in io.netty.resolver with parameters of type Promise Modifier and Type Method Description protected abstract voidAbstractAddressResolver. doResolve(T unresolvedAddress, Promise<T> promise)Invoked byAbstractAddressResolver.resolve(SocketAddress)to perform the actual name resolution.protected voidCompositeNameResolver. doResolve(java.lang.String inetHost, Promise<T> promise)protected voidDefaultNameResolver. doResolve(java.lang.String inetHost, Promise<java.net.InetAddress> promise)protected voidInetSocketAddressResolver. doResolve(java.net.InetSocketAddress unresolvedAddress, Promise<java.net.InetSocketAddress> promise)protected voidNoopAddressResolver. doResolve(java.net.SocketAddress unresolvedAddress, Promise<java.net.SocketAddress> promise)protected voidRoundRobinInetAddressResolver. doResolve(java.lang.String inetHost, Promise<java.net.InetAddress> promise)protected abstract voidSimpleNameResolver. doResolve(java.lang.String inetHost, Promise<T> promise)Invoked bySimpleNameResolver.resolve(String)to perform the actual name resolution.protected abstract voidAbstractAddressResolver. doResolveAll(T unresolvedAddress, Promise<java.util.List<T>> promise)Invoked byAbstractAddressResolver.resolveAll(SocketAddress)to perform the actual name resolution.protected voidCompositeNameResolver. doResolveAll(java.lang.String inetHost, Promise<java.util.List<T>> promise)protected voidDefaultNameResolver. doResolveAll(java.lang.String inetHost, Promise<java.util.List<java.net.InetAddress>> promise)protected voidInetSocketAddressResolver. doResolveAll(java.net.InetSocketAddress unresolvedAddress, Promise<java.util.List<java.net.InetSocketAddress>> promise)protected voidNoopAddressResolver. doResolveAll(java.net.SocketAddress unresolvedAddress, Promise<java.util.List<java.net.SocketAddress>> promise)protected voidRoundRobinInetAddressResolver. doResolveAll(java.lang.String inetHost, Promise<java.util.List<java.net.InetAddress>> promise)protected abstract voidSimpleNameResolver. doResolveAll(java.lang.String inetHost, Promise<java.util.List<T>> promise)Invoked bySimpleNameResolver.resolveAll(String)to perform the actual name resolution.private voidCompositeNameResolver. doResolveAllRec(java.lang.String inetHost, Promise<java.util.List<T>> promise, int resolverIndex, java.lang.Throwable lastFailure)private voidCompositeNameResolver. 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<Channel>DnsNameResolver.DnsResponseHandler. channelActivePromiseprivate Promise<?>DnsResolveContext. originalPromiseprivate Promise<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>>DnsQueryContext. promiseFields 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. resolveAllsInProgressprivate java.util.concurrent.ConcurrentMap<java.lang.String,Promise<java.util.List<T>>>InflightNameResolver. resolveAllsInProgressprivate java.util.concurrent.ConcurrentMap<java.lang.String,Promise<java.net.InetAddress>>DnsAddressResolverGroup. resolvesInProgressprivate java.util.concurrent.ConcurrentMap<java.lang.String,Promise<T>>InflightNameResolver. resolvesInProgressMethods 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)protected voidDnsNameResolver. 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 voidDnsNameResolver. doResolve(java.lang.String inetHost, Promise<java.net.InetAddress> promise)protected voidDnsNameResolver. 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 voidDnsNameResolver. doResolveAll(java.lang.String inetHost, Promise<java.util.List<java.net.InetAddress>> promise)(package private) static booleanDnsNameResolver. doResolveAllCached(java.lang.String hostname, DnsRecord[] additionals, Promise<java.util.List<java.net.InetAddress>> promise, DnsCache resolveCache, InternetProtocolFamily[] resolvedInternetProtocolFamilies)private voidDnsNameResolver. doResolveAllUncached(java.lang.String hostname, DnsRecord[] additionals, Promise<?> originalPromise, Promise<java.util.List<java.net.InetAddress>> promise, DnsCache resolveCache, boolean completeEarlyIfPossible)private voidDnsNameResolver. doResolveAllUncached0(java.lang.String hostname, DnsRecord[] additionals, Promise<?> originalPromise, Promise<java.util.List<java.net.InetAddress>> promise, DnsCache resolveCache, boolean completeEarlyIfPossible)private booleanDnsNameResolver. doResolveCached(java.lang.String hostname, DnsRecord[] additionals, Promise<java.net.InetAddress> promise, DnsCache resolveCache)private voidDnsNameResolver. doResolveUncached(java.lang.String hostname, DnsRecord[] additionals, Promise<java.net.InetAddress> promise, DnsCache resolveCache, boolean completeEarlyIfPossible)(package private) voidDnsAddressResolveContext. doSearchDomainQuery(java.lang.String hostname, Promise<java.util.List<java.net.InetAddress>> nextPromise)(package private) voidDnsResolveContext. doSearchDomainQuery(java.lang.String hostname, Promise<java.util.List<T>> nextPromise)private voidDnsResolveContext. finishResolve(Promise<java.util.List<T>> promise, java.lang.Throwable cause)private voidDnsResolveContext. followCname(DnsQuestion question, java.lang.String cname, DnsQueryLifecycleObserver queryLifecycleObserver, Promise<java.util.List<T>> promise)private booleanDnsResolveContext. handleRedirect(DnsQuestion question, AddressedEnvelope<DnsResponse,java.net.InetSocketAddress> envelope, DnsQueryLifecycleObserver queryLifecycleObserver, Promise<java.util.List<T>> promise)Handles a redirect answer if needed and returnstrueif a redirect query has been made.private voidDnsResolveContext. internalResolve(java.lang.String name, Promise<java.util.List<T>> promise)(package private) DnsResolveContext<java.net.InetAddress>DnsAddressResolveContext. newResolverContext(DnsNameResolver parent, Promise<?> originalPromise, java.lang.String hostname, int dnsClass, DnsRecordType[] expectedTypes, DnsRecord[] additionals, DnsServerAddressStream nameServerAddrs)(package private) DnsResolveContext<DnsRecord>DnsRecordResolveContext. newResolverContext(DnsNameResolver parent, Promise<?> originalPromise, java.lang.String hostname, int dnsClass, DnsRecordType[] expectedTypes, DnsRecord[] additionals, DnsServerAddressStream nameServerAddrs)(package private) abstract DnsResolveContext<T>DnsResolveContext. newResolverContext(DnsNameResolver parent, Promise<?> originalPromise, java.lang.String hostname, int dnsClass, DnsRecordType[] expectedTypes, DnsRecord[] additionals, DnsServerAddressStream nameServerAddrs)Creates a new context with the given parameters.private voidDnsResolveContext. onExpectedResponse(DnsQuestion question, AddressedEnvelope<DnsResponse,java.net.InetSocketAddress> envelope, DnsQueryLifecycleObserver queryLifecycleObserver, Promise<java.util.List<T>> promise)private voidDnsResolveContext. onResponse(DnsServerAddressStream nameServerAddrStream, int nameServerAddrStreamIndex, DnsQuestion question, AddressedEnvelope<DnsResponse,java.net.InetSocketAddress> envelope, DnsQueryLifecycleObserver queryLifecycleObserver, Promise<java.util.List<T>> promise)private voidDnsResolveContext. 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 voidDnsResolveContext. query(DnsServerAddressStream nameServerAddrStream, int nameServerAddrStreamIndex, DnsQuestion question, DnsQueryLifecycleObserver queryLifecycleObserver, boolean flush, Promise<java.util.List<T>> promise, java.lang.Throwable cause)private booleanDnsResolveContext. query(java.lang.String hostname, DnsRecordType type, DnsServerAddressStream dnsServerAddressStream, boolean flush, Promise<java.util.List<T>> promise)(package private) Future<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>>DnsNameResolver. query0(java.net.InetSocketAddress nameServerAddr, DnsQuestion question, DnsRecord[] additionals, boolean flush, ChannelPromise writePromise, Promise<AddressedEnvelope<? extends DnsResponse,java.net.InetSocketAddress>> promise)private voidDnsResolveContext. 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) voidDnsResolveContext. 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 theDnsRecords 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 static <T> voidInflightNameResolver. transferResult(Future<T> src, Promise<T> dst)private static voidDnsNameResolver. tryFailure(Promise<?> promise, java.lang.Throwable cause)(package private) static <T> voidDnsNameResolver. trySuccess(Promise<T> promise, T result)private voidDnsResolveContext. 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(DnsNameResolver parent, java.net.InetSocketAddress nameServerAddr, DnsQuestion question, DnsRecord[] additionals, Promise<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>> promise)DnsAddressResolveContext(DnsNameResolver parent, Promise<?> originalPromise, java.lang.String hostname, DnsRecord[] additionals, DnsServerAddressStream nameServerAddrs, DnsCache resolveCache, AuthoritativeDnsServerCache authoritativeDnsServerCache, boolean completeEarlyIfPossible)DnsQueryContext(DnsNameResolver parent, java.net.InetSocketAddress nameServerAddr, DnsQuestion question, DnsRecord[] additionals, Promise<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>> promise)DnsRecordResolveContext(DnsNameResolver parent, Promise<?> originalPromise, DnsQuestion question, DnsRecord[] additionals, DnsServerAddressStream nameServerAddrs)DnsRecordResolveContext(DnsNameResolver parent, Promise<?> originalPromise, java.lang.String hostname, int dnsClass, DnsRecordType[] expectedTypes, DnsRecord[] additionals, DnsServerAddressStream nameServerAddrs)DnsResolveContext(DnsNameResolver parent, Promise<?> originalPromise, java.lang.String hostname, int dnsClass, DnsRecordType[] expectedTypes, DnsRecord[] additionals, DnsServerAddressStream nameServerAddrs)DnsResponseHandler(Promise<Channel> channelActivePromise)TcpDnsQueryContext(DnsNameResolver parent, Channel channel, java.net.InetSocketAddress nameServerAddr, 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 theFuturethat 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 interfaceProgressivePromise<V>SpecialProgressiveFuturewhich is writable.Classes in io.netty.util.concurrent that implement Promise Modifier and Type Class Description classDefaultProgressivePromise<V>classDefaultPromise<V>(package private) static classImmediateEventExecutor.ImmediateProgressivePromise<V>(package private) static classImmediateEventExecutor.ImmediatePromise<V>(package private) classPromiseTask<V>(package private) classScheduledFutureTask<V>private static classUnorderedThreadPoolEventExecutor.RunnableScheduledFutureTask<V>Fields in io.netty.util.concurrent declared as Promise Modifier and Type Field Description private Promise<?>PromiseAggregator. aggregatePromiseDeprecated.private Promise<java.lang.Void>PromiseCombiner. aggregatePromiseprivate Promise<? super T>UnaryPromiseNotifier. promiseprivate Promise<? super V>[]PromiseNotifier. promisesprivate Promise<?>MultithreadEventExecutorGroup. terminationFutureprivate Promise<?>SingleThreadEventExecutor. terminationFutureprivate Promise<?>UnorderedThreadPoolEventExecutor. terminationFutureFields in io.netty.util.concurrent with type parameters of type Promise Modifier and Type Field Description private java.util.Set<Promise<V>>PromiseAggregator. pendingPromisesDeprecated.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 givenPromises to the aggregator.voidPromiseCombiner. add(Promise promise)Deprecated.Replaced byPromiseCombiner.add(Future).voidPromiseCombiner. addAll(Promise... promises)Deprecated.Replaced byPromiseCombiner.addAll(Future[])static <X> voidUnaryPromiseNotifier. cascadeTo(Future<X> completedFuture, Promise<? super X> promise)voidPromiseCombiner. 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) -
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. promiseMethods 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 PendingWritePendingWrite. newInstance(java.lang.Object msg, Promise<java.lang.Void> promise)Create a new emptyRecyclableArrayListinstancestatic voidPromiseNotificationUtil. tryCancel(Promise<?> p, InternalLogger logger)static voidPromiseNotificationUtil. tryFailure(Promise<?> p, java.lang.Throwable cause, InternalLogger logger)static <V> voidPromiseNotificationUtil. trySuccess(Promise<? super V> p, V result, InternalLogger logger)
-