Uses of Interface
io.netty5.util.concurrent.Promise

Packages that use Promise

Package	Description
io.netty5.channel	The core channel API which is asynchronous and event-driven abstraction of various transports such as a NIO Channel.
io.netty5.channel.internal	Internal utilities for channel implementations.
io.netty5.handler.codec.http2	Handlers for sending and receiving HTTP/2 frames.
io.netty5.handler.ssl	SSL · TLS implementation based on SSLEngine
io.netty5.handler.traffic	Implementation of a Traffic Shaping Handler and Dynamic Statistics.
io.netty5.resolver	Resolves an arbitrary string that represents the name of an endpoint into an address.
io.netty5.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.netty5.util	Utility classes used across multiple packages.
io.netty5.util.concurrent	Utility classes for concurrent / async tasks.
io.netty5.util.internal	Internal-use-only utilities which is not allowed to be used outside Netty.

Uses of Promise in io.netty5.channel

Methods in io.netty5.channel that return Promise

Modifier and Type	Method	Description
default <V> Promise<V>	ChannelOutboundInvoker.newPromise()
<V> Promise<V>	DefaultChannelPipeline.newPromise()
Promise<Void>	PendingWriteQueue.remove()	Removes a pending write operation and release its message via Resource.dispose(Object).

Methods in io.netty5.channel with parameters of type Promise

Modifier and Type	Method	Description
void	AbstractCoalescingBufferQueue.add(Buffer buf, Promise<Void> promise)	Add a buffer to the end of the queue and associate a promise with it that should be completed when all the buffer's bytes have been consumed from the queue and written.
void	PendingWriteQueue.add(Object msg, Promise<Void> promise)	Add the given msg and Promise.
void	AbstractCoalescingBufferQueue.addFirst(Buffer buf, Promise<Void> promise)	Add a buffer to the front of the queue and associate a promise with it that should be completed when all the buffer's bytes have been consumed from the queue and written.
void	ChannelOutboundBuffer.addMessage(Object msg, int size, Promise<Void> promise)	Add given message to this ChannelOutboundBuffer.
protected void	AbstractChannel.DefaultAbstractChannelPipeline.bindTransport(SocketAddress localAddress, Promise<Void> promise)
protected abstract void	DefaultChannelPipeline.bindTransport(SocketAddress localAddress, Promise<Void> promise)	Bind the SocketAddress to the transport and notify the Promise once the operation was completed.
protected void	AbstractChannel.closeTransport(Promise<Void> promise)
protected void	AbstractChannel.DefaultAbstractChannelPipeline.closeTransport(Promise<Void> promise)
protected abstract void	DefaultChannelPipeline.closeTransport(Promise<Void> promise)	Close the transport and notify the Promise once the operation was completed.
protected void	AbstractChannel.DefaultAbstractChannelPipeline.connectTransport(SocketAddress remoteAddress, SocketAddress localAddress, Promise<Void> promise)
protected abstract void	DefaultChannelPipeline.connectTransport(SocketAddress remoteAddress, SocketAddress localAddress, Promise<Void> promise)	Connect the transport with the given remote SocketAddress.
protected void	AbstractChannel.DefaultAbstractChannelPipeline.deregisterTransport(Promise<Void> promise)
protected void	AbstractChannel.deregisterTransport(Promise<Void> promise)
protected abstract void	DefaultChannelPipeline.deregisterTransport(Promise<Void> promise)	Deregister the transport of the EventLoop and notify the Promise once the operation was completed.
protected void	AbstractChannel.DefaultAbstractChannelPipeline.disconnectTransport(Promise<Void> promise)
protected abstract void	DefaultChannelPipeline.disconnectTransport(Promise<Void> promise)	Disconnect the transport and notify the Promise once the operation was completed.
protected boolean	AbstractChannel.ensureOpen(Promise<Void> promise)
protected void	AbstractChannel.DefaultAbstractChannelPipeline.registerTransport(Promise<Void> promise)
protected abstract void	DefaultChannelPipeline.registerTransport(Promise<Void> promise)	Register the transport and notify the Promise once the operation was completed.
Buffer	AbstractCoalescingBufferQueue.remove(BufferAllocator alloc, int bytes, Promise<Void> aggregatePromise)	Remove a Buffer from the queue with the specified number of bytes.
Buffer	CoalescingBufferQueue.remove(int bytes, Promise<Void> aggregatePromise)	Remove a Buffer from the queue with the specified number of bytes.
Buffer	AbstractCoalescingBufferQueue.removeFirst(Promise<Void> aggregatePromise)	Remove the first Buffer from the queue.
protected void	AbstractChannel.safeSetFailure(Promise<Void> promise, Throwable cause)	Marks the specified promise as failure.
protected void	AbstractChannel.safeSetSuccess(Promise<Void> promise)	Marks the specified promise as success.
protected void	AbstractChannel.DefaultAbstractChannelPipeline.sendOutboundEventTransport(Object event, Promise<Void> promise)
protected abstract void	DefaultChannelPipeline.sendOutboundEventTransport(Object event, Promise<Void> promise)	Send a custom outbound event on the transport.
protected void	AbstractChannel.DefaultAbstractChannelPipeline.shutdownTransport(ChannelShutdownDirection direction, Promise<Void> promise)
protected void	AbstractChannel.shutdownTransport(ChannelShutdownDirection direction, Promise<Void> promise)
protected abstract void	DefaultChannelPipeline.shutdownTransport(ChannelShutdownDirection direction, Promise<Void> promise)	Shutdown the given direction of the transport and notify the Promise once the operation was completed.
protected void	AbstractChannel.DefaultAbstractChannelPipeline.writeTransport(Object msg, Promise<Void> promise)
protected abstract void	DefaultChannelPipeline.writeTransport(Object msg, Promise<Void> promise)	Schedules a write operation on the transport.

Uses of Promise in io.netty5.channel.internal

Methods in io.netty5.channel.internal that return Promise

Modifier and Type	Method	Description
<V> Promise<V>	DelegatingChannelHandlerContext.newPromise()

Uses of Promise in io.netty5.handler.codec.http2

Fields in io.netty5.handler.codec.http2 declared as Promise

Modifier and Type	Field	Description
protected Promise<Void>	DefaultHttp2ConnectionEncoder.FlowControlledBase.promise

Methods in io.netty5.handler.codec.http2 with parameters of type Promise

Modifier and Type	Method	Description
void	DefaultHttp2Connection.close(Promise<Void> promise)
void	Http2Connection.close(Promise<Void> promise)	Close this connection.
Future<Http2StreamChannel>	Http2StreamChannelBootstrap.open(Promise<Http2StreamChannel> promise)	Open a new Http2StreamChannel to use and notifies the given Promise.
void	Http2StreamChannelBootstrap.open0(ChannelHandlerContext ctx, Promise<Http2StreamChannel> promise)	Deprecated. should not be used directly.

Uses of Promise in io.netty5.handler.ssl

Methods in io.netty5.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.netty5.handler.traffic

Methods in io.netty5.handler.traffic with parameters of type Promise

Modifier and Type	Method	Description
protected void	AbstractTrafficShapingHandler.submitWrite(ChannelHandlerContext ctx, Object msg, long delay, Promise<Void> promise)	Deprecated.
protected void	GlobalChannelTrafficShapingHandler.submitWrite(ChannelHandlerContext ctx, Object msg, long size, long writedelay, long now, Promise<Void> promise)

Uses of Promise in io.netty5.resolver

Methods in io.netty5.resolver with parameters of type Promise

Modifier and Type	Method	Description
protected abstract void	AbstractAddressResolver.doResolve(T unresolvedAddress, Promise<T> promise)	Invoked by AbstractAddressResolver.resolve(SocketAddress) to perform the actual name resolution.
protected void	CompositeNameResolver.doResolve(String inetHost, Promise<T> promise)
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	SimpleNameResolver.doResolve(String inetHost, Promise<T> promise)	Invoked by SimpleNameResolver.resolve(String) to perform the actual name resolution.
protected abstract void	AbstractAddressResolver.doResolveAll(T unresolvedAddress, Promise<List<T>> promise)	Invoked by AbstractAddressResolver.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 by SimpleNameResolver.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.netty5.resolver.dns

Methods in io.netty5.resolver.dns with parameters of type Promise

Modifier and Type	Method	Description
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)
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 the DnsRecords that are matched by the specified DnsQuestion.
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.netty5.util

Methods in io.netty5.util with parameters of type Promise

Modifier and Type	Method	Description
Future<OUT>	AsyncMapping.map(IN input, Promise<OUT> promise)	Returns the Future that will provide the result of the mapping.

Uses of Promise in io.netty5.util.concurrent

Classes in io.netty5.util.concurrent that implement Promise

Modifier and Type	Class	Description
class	DefaultPromise<V>

Methods in io.netty5.util.concurrent that return Promise

Modifier and Type	Method	Description
default <V> Promise<V>	EventExecutor.newPromise()	Return a new Promise.
<V> Promise<V>	FuturePromiseFactory.newPromise()	Return a new Promise.
<V> Promise<V>	ImmediateEventExecutor.newPromise()
Promise<V>	DefaultPromise.setFailure(Throwable cause)
Promise<V>	Promise.setFailure(Throwable cause)	Marks this promise as a failure and notifies all listeners attached to the future.
Promise<V>	DefaultPromise.setSuccess(V result)
Promise<V>	Promise.setSuccess(V result)	Marks this promise as a success and notifies all listeners attached to the future.

Methods in io.netty5.util.concurrent with parameters of type Promise

Modifier and Type	Method	Description
default Future<V>	Future.cascadeTo(Promise<? super V> promise)	Link the Future and Promise such that if the Future completes the Promise will be notified.
void	PromiseCombiner.finish(Promise<Void> aggregatePromise)	Sets the promise to be notified when all combined futures have finished.
protected static <V> RunnableScheduledFuture<V>	AbstractScheduledEventExecutor.newRunnableScheduledFuture(AbstractScheduledEventExecutor executor, Promise<V> promise, Callable<V> task, long deadlineNanos, long periodNanos)	Returns a new RunnableFuture build on top of the given Promise and Callable.

Uses of Promise in io.netty5.util.internal

Methods in io.netty5.util.internal that return Promise

Modifier and Type	Method	Description
Promise<Void>	PendingWrite.promise()
Promise<Void>	PendingWrite.recycleAndGet()	Recycle this instance and return the Promise.

Methods in io.netty5.util.internal with parameters of type Promise

Modifier and Type	Method	Description
static PendingWrite	PendingWrite.newInstance(Object msg, Promise<Void> promise)	Create a new empty RecyclableArrayList instance
static void	PromiseNotificationUtil.tryCancel(Promise<?> p, InternalLogger logger)	Try to cancel the Promise and log if logger is not null in case this fails.
static void	PromiseNotificationUtil.tryFailure(Promise<?> p, Throwable cause, InternalLogger logger)	Try to mark the Promise as failure and log if logger is not null in case this fails.
static <V> void	PromiseNotificationUtil.trySuccess(Promise<? super V> p, V result, InternalLogger logger)	Try to mark the Promise as success and log if logger is not null in case this fails.