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 forChannel
pools.io.netty.handler.codec.http2 Handlers for sending and receiving HTTP/2 frames.io.netty.handler.ssl SSL · TLS implementation based onSSLEngine
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 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 class
DefaultChannelProgressivePromise
The defaultChannelProgressivePromise
implementation.class
DefaultChannelPromise
The defaultChannelPromise
implementation.class
DelegatingChannelPromiseNotifier
class
VoidChannelPromise
-
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 aChannel
from thisChannelPool
.Future<Channel>
FixedChannelPool. acquire(Promise<Channel> promise)
Future<Channel>
SimpleChannelPool. acquire(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)
-
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<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.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 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.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
Methods in io.netty.resolver.dns with parameters of type Promise Modifier and Type Method Description 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)
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.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.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. -
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>
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()
default <V> Promise<V>
EventExecutor. newPromise()
Return a newPromise
.<V> Promise<V>
ImmediateEventExecutor. newPromise()
<V> Promise<V>
UnorderedThreadPoolEventExecutor. newPromise()
Deprecated.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>
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 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
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)
-