Uses of Interface
io.netty.util.concurrent.Promise
-
Packages that use Promise Package Description 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.pool Implementations and API forChannelpools.io.netty.handler.codec.http2 Handlers for sending and receiving HTTP/2 frames.io.netty.handler.ssl 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.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 classDefaultChannelProgressivePromiseThe defaultChannelProgressivePromiseimplementation.classDefaultChannelPromiseThe defaultChannelPromiseimplementation.classDelegatingChannelPromiseNotifierclassVoidChannelPromise -
Uses of Promise in io.netty.channel.pool
Methods 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)Future<Void>ChannelPool. release(Channel channel, Promise<Void> promise)Release aChannelback to thisChannelPool.Future<Void>FixedChannelPool. release(Channel channel, Promise<Void> promise)Future<Void>SimpleChannelPool. release(Channel channel, Promise<Void> promise) -
Uses of Promise in io.netty.handler.codec.http2
Methods in io.netty.handler.codec.http2 with parameters of type Promise Modifier and Type Method Description Future<Void>DefaultHttp2Connection. close(Promise<Void> promise)Future<Void>Http2Connection. close(Promise<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.ssl
Methods in io.netty.handler.ssl with parameters of type Promise Modifier and Type Method Description Future<Channel>SslHandler. renegotiate(Promise<Channel> promise)Performs TLS renegotiation. -
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(String inetHost, Promise<T> promise)protected voidDefaultNameResolver. doResolve(String inetHost, Promise<InetAddress> promise)protected voidInetSocketAddressResolver. doResolve(InetSocketAddress unresolvedAddress, Promise<InetSocketAddress> promise)protected voidNoopAddressResolver. doResolve(SocketAddress unresolvedAddress, Promise<SocketAddress> promise)protected voidRoundRobinInetAddressResolver. doResolve(String inetHost, Promise<InetAddress> promise)protected abstract voidSimpleNameResolver. doResolve(String inetHost, Promise<T> promise)Invoked bySimpleNameResolver.resolve(String)to perform the actual name resolution.protected abstract voidAbstractAddressResolver. doResolveAll(T unresolvedAddress, Promise<List<T>> promise)Invoked byAbstractAddressResolver.resolveAll(SocketAddress)to perform the actual name resolution.protected voidCompositeNameResolver. doResolveAll(String inetHost, Promise<List<T>> promise)protected voidDefaultNameResolver. doResolveAll(String inetHost, Promise<List<InetAddress>> promise)protected voidInetSocketAddressResolver. doResolveAll(InetSocketAddress unresolvedAddress, Promise<List<InetSocketAddress>> promise)protected voidNoopAddressResolver. doResolveAll(SocketAddress unresolvedAddress, Promise<List<SocketAddress>> promise)protected voidRoundRobinInetAddressResolver. doResolveAll(String inetHost, Promise<List<InetAddress>> promise)protected abstract voidSimpleNameResolver. doResolveAll(String inetHost, Promise<List<T>> promise)Invoked bySimpleNameResolver.resolveAll(String)to perform the actual name resolution.Future<T>AbstractAddressResolver. resolve(SocketAddress address, Promise<T> promise)Future<T>AddressResolver. resolve(SocketAddress address, Promise<T> promise)Resolves the specified address.Future<T>NameResolver. resolve(String inetHost, Promise<T> promise)Resolves the specified name into an address.Future<T>SimpleNameResolver. resolve(String inetHost, Promise<T> promise)Future<List<T>>AbstractAddressResolver. resolveAll(SocketAddress address, Promise<List<T>> promise)Future<List<T>>AddressResolver. resolveAll(SocketAddress address, Promise<List<T>> promise)Resolves the specified address.Future<List<T>>NameResolver. resolveAll(String inetHost, Promise<List<T>> promise)Resolves the specified host name and port into a list of address.Future<List<T>>SimpleNameResolver. resolveAll(String inetHost, Promise<List<T>> promise) -
Uses of Promise in io.netty.resolver.dns
Methods in io.netty.resolver.dns with parameters of type Promise Modifier and Type Method Description protected voidDnsNameResolver. 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 voidDnsNameResolver. doResolve(String inetHost, Promise<InetAddress> promise)protected voidDnsNameResolver. 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 voidDnsNameResolver. doResolveAll(String inetHost, Promise<List<InetAddress>> promise)Future<AddressedEnvelope<DnsResponse,InetSocketAddress>>DnsNameResolver. query(DnsQuestion question, Promise<AddressedEnvelope<? extends DnsResponse,InetSocketAddress>> promise)Sends a DNS query with the specified question.Future<AddressedEnvelope<DnsResponse,InetSocketAddress>>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.Future<AddressedEnvelope<DnsResponse,InetSocketAddress>>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.Future<InetAddress>DnsNameResolver. resolve(String inetHost, Iterable<DnsRecord> additionals, Promise<InetAddress> promise)Resolves the specified name into an address.Future<List<DnsRecord>>DnsNameResolver. resolveAll(DnsQuestion question, Iterable<DnsRecord> additionals, Promise<List<DnsRecord>> promise)Resolves theDnsRecords that are matched by the specifiedDnsQuestion.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. -
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>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(Throwable cause)Promise<V>Promise. setFailure(Throwable cause)Marks this future as a failure and notifies all listeners.Promise<V>DefaultPromise. setSuccess(V result)Promise<V>Promise. setSuccess(V result)Marks this future as a success and notifies all listeners.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 <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> voidUnaryPromiseNotifier. cascadeTo(Future<X> completedFuture, Promise<? super X> promise)Deprecated.voidPromiseCombiner. finish(Promise<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<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
Methods in io.netty.util.internal that return Promise Modifier and Type Method Description Promise<Void>PendingWrite. promise()Promise<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(Object msg, Promise<Void> promise)Create a new emptyRecyclableArrayListinstancestatic voidPromiseNotificationUtil. tryCancel(Promise<?> p, InternalLogger logger)static voidPromiseNotificationUtil. tryFailure(Promise<?> p, Throwable cause, InternalLogger logger)static <V> voidPromiseNotificationUtil. trySuccess(Promise<? super V> p, V result, InternalLogger logger)
-