Uses of Interface
io.netty.channel.ChannelPromise
-
Packages that use ChannelPromise 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.embedded A virtualChannel
that helps wrapping a series of handlers to unit test the handlers or use them in non-I/O context.io.netty.channel.epoll Optimized transport for linux which uses EPOLL Edge-Triggered Mode for maximal performance.io.netty.channel.kqueue BSD specific transport.io.netty.channel.local A virtual transport that enables the communication between the two parties in the same virtual machine.io.netty.channel.nio NIO-based channel API implementation - recommended for a large number of connections (>= 1000).io.netty.channel.oio Old blocking I/O based channel API implementation - recommended for a small number of connections (< 1000).io.netty.channel.sctp Abstract SCTP socket interfaces which extend the core channel API.io.netty.channel.sctp.nio NIO-based SCTP Channel API implementation - recommended for a large number of connections (>= 1000).io.netty.channel.sctp.oio Old blocking I/O based SCTP channel API implementation - recommended for a small number of connections (< 1000).io.netty.channel.socket Abstract TCP and UDP socket interfaces which extend the core channel API.io.netty.channel.socket.nio NIO-based socket channel API implementation - recommended for a large number of connections (>= 1000).io.netty.channel.socket.oio Old blocking I/O based socket channel API implementation - recommended for a small number of connections (< 1000).io.netty.handler.address Package to dynamically replace local / remoteSocketAddress
.io.netty.handler.codec Extensible decoder and its common implementations which deal with the packet fragmentation and reassembly issue found in a stream-based transport such as TCP/IP.io.netty.handler.codec.compression io.netty.handler.codec.http Encoder, decoder and their related message types for HTTP.io.netty.handler.codec.http.cors This package contains Cross Origin Resource Sharing (CORS) related classes.io.netty.handler.codec.http.websocketx Encoder, decoder, handshakers and their related message types for Web Socket data frames.io.netty.handler.codec.http.websocketx.extensions Encoder, decoder, handshakers to handle WebSocket Extensions.io.netty.handler.codec.http2 Handlers for sending and receiving HTTP/2 frames.io.netty.handler.codec.spdy Encoder, decoder, session handler and their related message types for the SPDY protocol.io.netty.handler.flush Package to control flush behavior.io.netty.handler.logging Logs the I/O events for debugging purpose.io.netty.handler.pcap Capture data and write into Pcap format which helps in troubleshooting.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.stream Writes very large data stream asynchronously neither spending a lot of memory nor gettingOutOfMemoryError
.io.netty.handler.timeout Adds support for read and write timeout and idle connection notification using aTimer
.io.netty.handler.traffic Implementation of a Traffic Shaping Handler and Dynamic Statistics.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. -
-
Uses of ChannelPromise in io.netty.bootstrap
Classes in io.netty.bootstrap that implement ChannelPromise Modifier and Type Class Description (package private) static class
AbstractBootstrap.PendingRegistrationPromise
Methods in io.netty.bootstrap with parameters of type ChannelPromise Modifier and Type Method Description void
FailedChannel.FailedChannelUnsafe. connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
private static void
AbstractBootstrap. doBind0(ChannelFuture regFuture, Channel channel, java.net.SocketAddress localAddress, ChannelPromise promise)
private static void
Bootstrap. doConnect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise connectPromise)
private ChannelFuture
Bootstrap. doResolveAndConnect0(Channel channel, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
-
Uses of ChannelPromise in io.netty.channel
Subinterfaces of ChannelPromise in io.netty.channel Modifier and Type Interface Description interface
ChannelProgressivePromise
SpecialChannelPromise
which will be notified once the associated bytes is transferring.Classes in io.netty.channel that implement ChannelPromise 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 ChannelPromise Modifier and Type Field Description private ChannelPromise
DelegatingChannelPromiseNotifier. delegate
private ChannelPromise
ChannelFlushPromiseNotifier.DefaultFlushCheckpoint. future
private ChannelPromise
AbstractChannelHandlerContext.WriteTask. promise
(package private) ChannelPromise
ChannelOutboundBuffer.Entry. promise
private ChannelPromise
PendingWriteQueue.PendingWrite. promise
Methods in io.netty.channel that return ChannelPromise Modifier and Type Method Description ChannelPromise
ChannelPromise. addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
ChannelPromise
DefaultChannelPromise. addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
ChannelPromise
DelegatingChannelPromiseNotifier. addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
ChannelPromise
ChannelPromise. addListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners)
ChannelPromise
DefaultChannelPromise. addListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners)
ChannelPromise
DelegatingChannelPromiseNotifier. addListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners)
ChannelPromise
ChannelPromise. await()
ChannelPromise
DefaultChannelPromise. await()
ChannelPromise
DelegatingChannelPromiseNotifier. await()
ChannelPromise
ChannelPromise. awaitUninterruptibly()
ChannelPromise
DefaultChannelPromise. awaitUninterruptibly()
ChannelPromise
DelegatingChannelPromiseNotifier. awaitUninterruptibly()
ChannelPromise
AbstractChannel. newPromise()
ChannelPromise
AbstractChannelHandlerContext. newPromise()
ChannelPromise
ChannelOutboundInvoker. newPromise()
Return a newChannelPromise
.ChannelPromise
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext. newPromise()
ChannelPromise
DefaultChannelPipeline. newPromise()
ChannelPromise
ChannelFlushPromiseNotifier.DefaultFlushCheckpoint. promise()
ChannelPromise
ChannelFlushPromiseNotifier.FlushCheckpoint. promise()
ChannelPromise
DefaultChannelPromise. promise()
ChannelPromise
PendingWriteQueue. remove()
Removes a pending write operation and release it's message viaReferenceCountUtil.safeRelease(Object)
.ChannelPromise
ChannelPromise. removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
ChannelPromise
DefaultChannelPromise. removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
ChannelPromise
DelegatingChannelPromiseNotifier. removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
ChannelPromise
ChannelPromise. removeListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners)
ChannelPromise
DefaultChannelPromise. removeListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners)
ChannelPromise
DelegatingChannelPromiseNotifier. removeListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners)
ChannelPromise
AbstractChannel.CloseFuture. setFailure(java.lang.Throwable cause)
ChannelPromise
ChannelPromise. setFailure(java.lang.Throwable cause)
ChannelPromise
DefaultChannelPromise. setFailure(java.lang.Throwable cause)
ChannelPromise
DelegatingChannelPromiseNotifier. setFailure(java.lang.Throwable cause)
ChannelPromise
AbstractChannel.CloseFuture. setSuccess()
ChannelPromise
ChannelPromise. setSuccess()
ChannelPromise
ChannelPromise. setSuccess(java.lang.Void result)
ChannelPromise
DefaultChannelPromise. setSuccess()
ChannelPromise
DefaultChannelPromise. setSuccess(java.lang.Void result)
ChannelPromise
DelegatingChannelPromiseNotifier. setSuccess()
ChannelPromise
DelegatingChannelPromiseNotifier. setSuccess(java.lang.Void result)
ChannelPromise
ChannelPromise. sync()
ChannelPromise
DefaultChannelPromise. sync()
ChannelPromise
DelegatingChannelPromiseNotifier. sync()
ChannelPromise
ChannelPromise. syncUninterruptibly()
ChannelPromise
DefaultChannelPromise. syncUninterruptibly()
ChannelPromise
DelegatingChannelPromiseNotifier. syncUninterruptibly()
ChannelPromise
ChannelPromise. unvoid()
ChannelPromise
DefaultChannelPromise. unvoid()
ChannelPromise
DelegatingChannelPromiseNotifier. unvoid()
ChannelPromise
VoidChannelPromise. unvoid()
ChannelPromise
AbstractChannel.AbstractUnsafe. voidPromise()
ChannelPromise
AbstractChannel. voidPromise()
ChannelPromise
AbstractChannelHandlerContext. voidPromise()
ChannelPromise
Channel.Unsafe. voidPromise()
Return a special ChannelPromise which can be reused and passed to the operations inChannel.Unsafe
.ChannelPromise
ChannelOutboundInvoker. voidPromise()
Return a special ChannelPromise which can be reused for different operations.ChannelPromise
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext. voidPromise()
ChannelPromise
DefaultChannelPipeline. voidPromise()
Methods in io.netty.channel with parameters of type ChannelPromise Modifier and Type Method Description void
AbstractCoalescingBufferQueue. add(ByteBuf buf, ChannelPromise 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.ChannelFlushPromiseNotifier
ChannelFlushPromiseNotifier. add(ChannelPromise promise, int pendingDataSize)
Deprecated.ChannelFlushPromiseNotifier
ChannelFlushPromiseNotifier. add(ChannelPromise promise, long pendingDataSize)
Add aChannelPromise
to thisChannelFlushPromiseNotifier
which will be notified after the givenpendingDataSize
was reached.void
PendingWriteQueue. add(java.lang.Object msg, ChannelPromise promise)
Add the givenmsg
andChannelPromise
.void
AbstractCoalescingBufferQueue. addFirst(ByteBuf buf, ChannelPromise 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(java.lang.Object msg, int size, ChannelPromise promise)
Add given message to thisChannelOutboundBuffer
.void
AbstractChannel.AbstractUnsafe. bind(java.net.SocketAddress localAddress, ChannelPromise promise)
ChannelFuture
AbstractChannel. bind(java.net.SocketAddress localAddress, ChannelPromise promise)
ChannelFuture
AbstractChannelHandlerContext. bind(java.net.SocketAddress localAddress, ChannelPromise promise)
void
Channel.Unsafe. bind(java.net.SocketAddress localAddress, ChannelPromise promise)
void
ChannelDuplexHandler. bind(ChannelHandlerContext ctx, java.net.SocketAddress localAddress, ChannelPromise promise)
CallsChannelOutboundInvoker.bind(SocketAddress, ChannelPromise)
to forward to the nextChannelOutboundHandler
in theChannelPipeline
.void
ChannelOutboundHandler. bind(ChannelHandlerContext ctx, java.net.SocketAddress localAddress, ChannelPromise promise)
Called once a bind operation is made.void
ChannelOutboundHandlerAdapter. bind(ChannelHandlerContext ctx, java.net.SocketAddress localAddress, ChannelPromise promise)
CallsChannelOutboundInvoker.bind(SocketAddress, ChannelPromise)
to forward to the nextChannelOutboundHandler
in theChannelPipeline
.ChannelFuture
ChannelOutboundInvoker. bind(java.net.SocketAddress localAddress, ChannelPromise promise)
Request to bind to the givenSocketAddress
and notify theChannelFuture
once the operation completes, either because the operation was successful or because of an error.void
CombinedChannelDuplexHandler. bind(ChannelHandlerContext ctx, java.net.SocketAddress localAddress, ChannelPromise promise)
ChannelFuture
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext. bind(java.net.SocketAddress localAddress, ChannelPromise promise)
ChannelFuture
DefaultChannelPipeline. bind(java.net.SocketAddress localAddress, ChannelPromise promise)
void
DefaultChannelPipeline.HeadContext. bind(ChannelHandlerContext ctx, java.net.SocketAddress localAddress, ChannelPromise promise)
void
AbstractChannel.AbstractUnsafe. close(ChannelPromise promise)
private void
AbstractChannel.AbstractUnsafe. close(ChannelPromise promise, java.lang.Throwable cause, java.nio.channels.ClosedChannelException closeCause, boolean notify)
ChannelFuture
AbstractChannel. close(ChannelPromise promise)
ChannelFuture
AbstractChannelHandlerContext. close(ChannelPromise promise)
void
Channel.Unsafe. close(ChannelPromise promise)
Close theChannel
of theChannelPromise
and notify theChannelPromise
once the operation was complete.void
ChannelDuplexHandler. close(ChannelHandlerContext ctx, ChannelPromise promise)
CallsChannelOutboundInvoker.close(ChannelPromise)
to forward to the nextChannelOutboundHandler
in theChannelPipeline
.void
ChannelOutboundHandler. close(ChannelHandlerContext ctx, ChannelPromise promise)
Called once a close operation is made.void
ChannelOutboundHandlerAdapter. close(ChannelHandlerContext ctx, ChannelPromise promise)
CallsChannelOutboundInvoker.close(ChannelPromise)
to forward to the nextChannelOutboundHandler
in theChannelPipeline
.ChannelFuture
ChannelOutboundInvoker. close(ChannelPromise promise)
Request to close theChannel
and notify theChannelFuture
once the operation completes, either because the operation was successful or because of an error.void
CombinedChannelDuplexHandler. close(ChannelHandlerContext ctx, ChannelPromise promise)
ChannelFuture
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext. close(ChannelPromise promise)
ChannelFuture
DefaultChannelPipeline. close(ChannelPromise promise)
void
DefaultChannelPipeline.HeadContext. close(ChannelHandlerContext ctx, ChannelPromise promise)
ChannelFuture
AbstractChannel. connect(java.net.SocketAddress remoteAddress, ChannelPromise promise)
ChannelFuture
AbstractChannel. connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
ChannelFuture
AbstractChannelHandlerContext. connect(java.net.SocketAddress remoteAddress, ChannelPromise promise)
ChannelFuture
AbstractChannelHandlerContext. connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
void
AbstractServerChannel.DefaultServerUnsafe. connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
void
Channel.Unsafe. connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
void
ChannelDuplexHandler. connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
CallsChannelOutboundInvoker.connect(SocketAddress, SocketAddress, ChannelPromise)
to forward to the nextChannelOutboundHandler
in theChannelPipeline
.void
ChannelOutboundHandler. connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
Called once a connect operation is made.void
ChannelOutboundHandlerAdapter. connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
CallsChannelOutboundInvoker.connect(SocketAddress, SocketAddress, ChannelPromise)
to forward to the nextChannelOutboundHandler
in theChannelPipeline
.ChannelFuture
ChannelOutboundInvoker. connect(java.net.SocketAddress remoteAddress, ChannelPromise promise)
Request to connect to the givenSocketAddress
and notify theChannelFuture
once the operation completes, either because the operation was successful or because of an error.ChannelFuture
ChannelOutboundInvoker. connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
Request to connect to the givenSocketAddress
while bind to the localAddress and notify theChannelFuture
once the operation completes, either because the operation was successful or because of an error.void
CombinedChannelDuplexHandler. connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
ChannelFuture
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext. connect(java.net.SocketAddress remoteAddress, ChannelPromise promise)
ChannelFuture
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext. connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
ChannelFuture
DefaultChannelPipeline. connect(java.net.SocketAddress remoteAddress, ChannelPromise promise)
ChannelFuture
DefaultChannelPipeline. connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
void
DefaultChannelPipeline.HeadContext. connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
void
AbstractChannel.AbstractUnsafe. deregister(ChannelPromise promise)
private void
AbstractChannel.AbstractUnsafe. deregister(ChannelPromise promise, boolean fireChannelInactive)
ChannelFuture
AbstractChannel. deregister(ChannelPromise promise)
ChannelFuture
AbstractChannelHandlerContext. deregister(ChannelPromise promise)
void
Channel.Unsafe. deregister(ChannelPromise promise)
Deregister theChannel
of theChannelPromise
fromEventLoop
and notify theChannelPromise
once the operation was complete.void
ChannelDuplexHandler. deregister(ChannelHandlerContext ctx, ChannelPromise promise)
CallsChannelOutboundInvoker.deregister(ChannelPromise)
to forward to the nextChannelOutboundHandler
in theChannelPipeline
.void
ChannelOutboundHandler. deregister(ChannelHandlerContext ctx, ChannelPromise promise)
Called once a deregister operation is made from the current registeredEventLoop
.void
ChannelOutboundHandlerAdapter. deregister(ChannelHandlerContext ctx, ChannelPromise promise)
CallsChannelOutboundInvoker.deregister(ChannelPromise)
to forward to the nextChannelOutboundHandler
in theChannelPipeline
.ChannelFuture
ChannelOutboundInvoker. deregister(ChannelPromise promise)
Request to deregister from the previous assignedEventExecutor
and notify theChannelFuture
once the operation completes, either because the operation was successful or because of an error.ChannelFuture
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext. deregister(ChannelPromise promise)
void
CombinedChannelDuplexHandler. deregister(ChannelHandlerContext ctx, ChannelPromise promise)
ChannelFuture
DefaultChannelPipeline. deregister(ChannelPromise promise)
void
DefaultChannelPipeline.HeadContext. deregister(ChannelHandlerContext ctx, ChannelPromise promise)
void
AbstractChannel.AbstractUnsafe. disconnect(ChannelPromise promise)
ChannelFuture
AbstractChannel. disconnect(ChannelPromise promise)
ChannelFuture
AbstractChannelHandlerContext. disconnect(ChannelPromise promise)
void
Channel.Unsafe. disconnect(ChannelPromise promise)
Disconnect theChannel
of theChannelFuture
and notify theChannelPromise
once the operation was complete.void
ChannelDuplexHandler. disconnect(ChannelHandlerContext ctx, ChannelPromise promise)
CallsChannelOutboundInvoker.disconnect(ChannelPromise)
to forward to the nextChannelOutboundHandler
in theChannelPipeline
.void
ChannelOutboundHandler. disconnect(ChannelHandlerContext ctx, ChannelPromise promise)
Called once a disconnect operation is made.void
ChannelOutboundHandlerAdapter. disconnect(ChannelHandlerContext ctx, ChannelPromise promise)
CallsChannelOutboundInvoker.disconnect(ChannelPromise)
to forward to the nextChannelOutboundHandler
in theChannelPipeline
.ChannelFuture
ChannelOutboundInvoker. disconnect(ChannelPromise promise)
Request to disconnect from the remote peer and notify theChannelFuture
once the operation completes, either because the operation was successful or because of an error.ChannelFuture
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext. disconnect(ChannelPromise promise)
void
CombinedChannelDuplexHandler. disconnect(ChannelHandlerContext ctx, ChannelPromise promise)
ChannelFuture
DefaultChannelPipeline. disconnect(ChannelPromise promise)
void
DefaultChannelPipeline.HeadContext. disconnect(ChannelHandlerContext ctx, ChannelPromise promise)
private void
AbstractChannel.AbstractUnsafe. doClose0(ChannelPromise promise)
protected boolean
AbstractChannel.AbstractUnsafe. ensureOpen(ChannelPromise promise)
protected static void
AbstractChannelHandlerContext.WriteTask. init(AbstractChannelHandlerContext.WriteTask task, AbstractChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise, boolean flush)
private void
AbstractChannelHandlerContext. invokeBind(java.net.SocketAddress localAddress, ChannelPromise promise)
private void
AbstractChannelHandlerContext. invokeClose(ChannelPromise promise)
private void
AbstractChannelHandlerContext. invokeConnect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
private void
AbstractChannelHandlerContext. invokeDeregister(ChannelPromise promise)
private void
AbstractChannelHandlerContext. invokeDisconnect(ChannelPromise promise)
(package private) void
AbstractChannelHandlerContext. invokeWrite(java.lang.Object msg, ChannelPromise promise)
private void
AbstractChannelHandlerContext. invokeWrite0(java.lang.Object msg, ChannelPromise promise)
(package private) void
AbstractChannelHandlerContext. invokeWriteAndFlush(java.lang.Object msg, ChannelPromise promise)
private boolean
AbstractChannelHandlerContext. isNotValidPromise(ChannelPromise promise, boolean allowVoidPromise)
(package private) static AbstractChannelHandlerContext.WriteTask
AbstractChannelHandlerContext.WriteTask. newInstance(AbstractChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise, boolean flush)
(package private) static ChannelOutboundBuffer.Entry
ChannelOutboundBuffer.Entry. newInstance(java.lang.Object msg, int size, long total, ChannelPromise promise)
(package private) static PendingWriteQueue.PendingWrite
PendingWriteQueue.PendingWrite. newInstance(java.lang.Object msg, int size, ChannelPromise promise)
private static void
AbstractChannelHandlerContext. notifyOutboundHandlerException(java.lang.Throwable cause, ChannelPromise promise)
void
AbstractChannel.AbstractUnsafe. register(EventLoop eventLoop, ChannelPromise promise)
void
Channel.Unsafe. register(EventLoop eventLoop, ChannelPromise promise)
Register theChannel
of theChannelPromise
and notify theChannelFuture
once the registration was complete.ChannelFuture
EventLoopGroup. register(ChannelPromise promise)
ChannelFuture
EventLoopGroup. register(Channel channel, ChannelPromise promise)
Deprecated.UseEventLoopGroup.register(ChannelPromise)
instead.ChannelFuture
MultithreadEventLoopGroup. register(ChannelPromise promise)
ChannelFuture
MultithreadEventLoopGroup. register(Channel channel, ChannelPromise promise)
Deprecated.ChannelFuture
SingleThreadEventLoop. register(ChannelPromise promise)
ChannelFuture
SingleThreadEventLoop. register(Channel channel, ChannelPromise promise)
Deprecated.ChannelFuture
ThreadPerChannelEventLoop. register(ChannelPromise promise)
Deprecated.ChannelFuture
ThreadPerChannelEventLoop. register(Channel channel, ChannelPromise promise)
Deprecated.ChannelFuture
ThreadPerChannelEventLoopGroup. register(ChannelPromise promise)
Deprecated.ChannelFuture
ThreadPerChannelEventLoopGroup. register(Channel channel, ChannelPromise promise)
Deprecated.private void
AbstractChannel.AbstractUnsafe. register0(ChannelPromise promise)
ByteBuf
AbstractCoalescingBufferQueue. remove(ByteBufAllocator alloc, int bytes, ChannelPromise aggregatePromise)
Remove aByteBuf
from the queue with the specified number of bytes.ByteBuf
CoalescingBufferQueue. remove(int bytes, ChannelPromise aggregatePromise)
Remove aByteBuf
from the queue with the specified number of bytes.ByteBuf
AbstractCoalescingBufferQueue. removeFirst(ChannelPromise aggregatePromise)
Remove the firstByteBuf
from the queue.private static boolean
AbstractChannelHandlerContext. safeExecute(EventExecutor executor, java.lang.Runnable runnable, ChannelPromise promise, java.lang.Object msg, boolean lazy)
private static void
ChannelOutboundBuffer. safeFail(ChannelPromise promise, java.lang.Throwable cause)
private static void
PendingWriteQueue. safeFail(ChannelPromise promise, java.lang.Throwable cause)
protected void
AbstractChannel.AbstractUnsafe. safeSetFailure(ChannelPromise promise, java.lang.Throwable cause)
Marks the specifiedpromise
as failure.protected void
AbstractChannel.AbstractUnsafe. safeSetSuccess(ChannelPromise promise)
Marks the specifiedpromise
as success.private static void
ChannelOutboundBuffer. safeSuccess(ChannelPromise promise)
void
AbstractChannel.AbstractUnsafe. shutdownOutput(ChannelPromise promise)
Shutdown the output portion of the correspondingChannel
.private void
AbstractChannel.AbstractUnsafe. shutdownOutput(ChannelPromise promise, java.lang.Throwable cause)
Shutdown the output portion of the correspondingChannel
.private static ChannelFutureListener
AbstractCoalescingBufferQueue. toChannelFutureListener(ChannelPromise promise)
void
AbstractChannel.AbstractUnsafe. write(java.lang.Object msg, ChannelPromise promise)
ChannelFuture
AbstractChannel. write(java.lang.Object msg, ChannelPromise promise)
private void
AbstractChannelHandlerContext. write(java.lang.Object msg, boolean flush, ChannelPromise promise)
ChannelFuture
AbstractChannelHandlerContext. write(java.lang.Object msg, ChannelPromise promise)
void
Channel.Unsafe. write(java.lang.Object msg, ChannelPromise promise)
Schedules a write operation.void
ChannelDuplexHandler. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)
CallsChannelOutboundInvoker.write(Object, ChannelPromise)
to forward to the nextChannelOutboundHandler
in theChannelPipeline
.void
ChannelOutboundHandler. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)
Called once a write operation is made.void
ChannelOutboundHandlerAdapter. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)
CallsChannelOutboundInvoker.write(Object, ChannelPromise)
to forward to the nextChannelOutboundHandler
in theChannelPipeline
.ChannelFuture
ChannelOutboundInvoker. write(java.lang.Object msg, ChannelPromise promise)
Request to write a message via thisChannelHandlerContext
through theChannelPipeline
.ChannelFuture
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext. write(java.lang.Object msg, ChannelPromise promise)
void
CombinedChannelDuplexHandler. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)
void
DefaultChannelPipeline.HeadContext. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)
ChannelFuture
DefaultChannelPipeline. write(java.lang.Object msg, ChannelPromise promise)
ChannelFuture
AbstractChannel. writeAndFlush(java.lang.Object msg, ChannelPromise promise)
ChannelFuture
AbstractChannelHandlerContext. writeAndFlush(java.lang.Object msg, ChannelPromise promise)
ChannelFuture
ChannelOutboundInvoker. writeAndFlush(java.lang.Object msg, ChannelPromise promise)
Shortcut for callChannelOutboundInvoker.write(Object, ChannelPromise)
andChannelOutboundInvoker.flush()
.ChannelFuture
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext. writeAndFlush(java.lang.Object msg, ChannelPromise promise)
ChannelFuture
DefaultChannelPipeline. writeAndFlush(java.lang.Object msg, ChannelPromise promise)
Constructors in io.netty.channel with parameters of type ChannelPromise Constructor Description ChannelPromiseAggregator(ChannelPromise aggregatePromise)
Deprecated.ChannelPromiseNotifier(boolean logNotifyFailure, ChannelPromise... promises)
Deprecated.Create a new instanceChannelPromiseNotifier(ChannelPromise... promises)
Deprecated.Create a new instanceDefaultFlushCheckpoint(long checkpoint, ChannelPromise future)
DelegatingChannelPromiseNotifier(ChannelPromise delegate)
DelegatingChannelPromiseNotifier(ChannelPromise delegate, boolean logNotifyFailure)
-
Uses of ChannelPromise in io.netty.channel.embedded
Methods in io.netty.channel.embedded with parameters of type ChannelPromise Modifier and Type Method Description ChannelFuture
EmbeddedChannel. bind(java.net.SocketAddress localAddress, ChannelPromise promise)
private ChannelFuture
EmbeddedChannel. checkException(ChannelPromise promise)
Checks for the presence of anException
.ChannelFuture
EmbeddedChannel. close(ChannelPromise promise)
ChannelFuture
EmbeddedChannel. connect(java.net.SocketAddress remoteAddress, ChannelPromise promise)
ChannelFuture
EmbeddedChannel. connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
void
EmbeddedChannel.EmbeddedUnsafe. connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
ChannelFuture
EmbeddedChannel. deregister(ChannelPromise promise)
ChannelFuture
EmbeddedChannel. disconnect(ChannelPromise promise)
private ChannelFuture
EmbeddedChannel. flushInbound(boolean recordException, ChannelPromise promise)
ChannelFuture
EmbeddedEventLoop. register(ChannelPromise promise)
ChannelFuture
EmbeddedEventLoop. register(Channel channel, ChannelPromise promise)
Deprecated.ChannelFuture
EmbeddedChannel. write(java.lang.Object msg, ChannelPromise promise)
ChannelFuture
EmbeddedChannel. writeAndFlush(java.lang.Object msg, ChannelPromise promise)
ChannelFuture
EmbeddedChannel. writeOneInbound(java.lang.Object msg, ChannelPromise promise)
Writes one message to the inbound of thisChannel
and does not flush it.ChannelFuture
EmbeddedChannel. writeOneOutbound(java.lang.Object msg, ChannelPromise promise)
Writes one message to the outbound of thisChannel
and does not flush it. -
Uses of ChannelPromise in io.netty.channel.epoll
Fields in io.netty.channel.epoll declared as ChannelPromise Modifier and Type Field Description private ChannelPromise
AbstractEpollChannel. connectPromise
The future of the current connection attempt.private ChannelPromise
AbstractEpollStreamChannel.SpliceFdTask. promise
(package private) ChannelPromise
AbstractEpollStreamChannel.SpliceInTask. promise
Methods in io.netty.channel.epoll with parameters of type ChannelPromise Modifier and Type Method Description ChannelFuture
EpollDatagramChannel. block(java.net.InetAddress multicastAddress, java.net.InetAddress sourceToBlock, ChannelPromise promise)
ChannelFuture
EpollDatagramChannel. block(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress sourceToBlock, ChannelPromise promise)
void
AbstractEpollChannel.AbstractEpollUnsafe. connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
void
AbstractEpollServerChannel.EpollServerSocketUnsafe. connect(java.net.SocketAddress socketAddress, java.net.SocketAddress socketAddress2, ChannelPromise channelPromise)
private void
AbstractEpollStreamChannel. failSpliceIfClosed(ChannelPromise promise)
private void
AbstractEpollChannel.AbstractEpollUnsafe. fulfillConnectPromise(ChannelPromise promise, boolean wasActive)
private void
AbstractEpollChannel.AbstractEpollUnsafe. fulfillConnectPromise(ChannelPromise promise, java.lang.Throwable cause)
ChannelFuture
EpollDatagramChannel. joinGroup(java.net.InetAddress multicastAddress, ChannelPromise promise)
ChannelFuture
EpollDatagramChannel. joinGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source, ChannelPromise promise)
ChannelFuture
EpollDatagramChannel. joinGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface, ChannelPromise promise)
private void
EpollDatagramChannel. joinGroup0(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source, ChannelPromise promise)
ChannelFuture
EpollDatagramChannel. leaveGroup(java.net.InetAddress multicastAddress, ChannelPromise promise)
ChannelFuture
EpollDatagramChannel. leaveGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source, ChannelPromise promise)
ChannelFuture
EpollDatagramChannel. leaveGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface, ChannelPromise promise)
private void
EpollDatagramChannel. leaveGroup0(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source, ChannelPromise promise)
ChannelFuture
AbstractEpollStreamChannel. shutdown(ChannelPromise promise)
private static void
AbstractEpollStreamChannel. shutdownDone(ChannelFuture shutdownOutputFuture, ChannelFuture shutdownInputFuture, ChannelPromise promise)
ChannelFuture
AbstractEpollStreamChannel. shutdownInput(ChannelPromise promise)
private void
AbstractEpollStreamChannel. shutdownInput0(ChannelPromise promise)
ChannelFuture
AbstractEpollStreamChannel. shutdownOutput(ChannelPromise promise)
private void
AbstractEpollStreamChannel. shutdownOutputDone(ChannelFuture shutdownOutputFuture, ChannelPromise promise)
ChannelFuture
AbstractEpollStreamChannel. spliceTo(AbstractEpollStreamChannel ch, int len, ChannelPromise promise)
Splice from thisAbstractEpollStreamChannel
to anotherAbstractEpollStreamChannel
.ChannelFuture
AbstractEpollStreamChannel. spliceTo(FileDescriptor ch, int offset, int len, ChannelPromise promise)
Splice from thisAbstractEpollStreamChannel
to anotherFileDescriptor
.Constructors in io.netty.channel.epoll with parameters of type ChannelPromise Constructor Description SpliceFdTask(FileDescriptor fd, int offset, int len, ChannelPromise promise)
SpliceInChannelTask(AbstractEpollStreamChannel ch, int len, ChannelPromise promise)
SpliceInTask(int len, ChannelPromise promise)
-
Uses of ChannelPromise in io.netty.channel.kqueue
Fields in io.netty.channel.kqueue declared as ChannelPromise Modifier and Type Field Description private ChannelPromise
AbstractKQueueChannel. connectPromise
The future of the current connection attempt.Methods in io.netty.channel.kqueue with parameters of type ChannelPromise Modifier and Type Method Description ChannelFuture
KQueueDatagramChannel. block(java.net.InetAddress multicastAddress, java.net.InetAddress sourceToBlock, ChannelPromise promise)
ChannelFuture
KQueueDatagramChannel. block(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress sourceToBlock, ChannelPromise promise)
void
AbstractKQueueChannel.AbstractKQueueUnsafe. connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
private void
AbstractKQueueChannel.AbstractKQueueUnsafe. fulfillConnectPromise(ChannelPromise promise, boolean wasActive)
private void
AbstractKQueueChannel.AbstractKQueueUnsafe. fulfillConnectPromise(ChannelPromise promise, java.lang.Throwable cause)
ChannelFuture
KQueueDatagramChannel. joinGroup(java.net.InetAddress multicastAddress, ChannelPromise promise)
ChannelFuture
KQueueDatagramChannel. joinGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source, ChannelPromise promise)
ChannelFuture
KQueueDatagramChannel. joinGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface, ChannelPromise promise)
ChannelFuture
KQueueDatagramChannel. leaveGroup(java.net.InetAddress multicastAddress, ChannelPromise promise)
ChannelFuture
KQueueDatagramChannel. leaveGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source, ChannelPromise promise)
ChannelFuture
KQueueDatagramChannel. leaveGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface, ChannelPromise promise)
ChannelFuture
AbstractKQueueStreamChannel. shutdown(ChannelPromise promise)
private static void
AbstractKQueueStreamChannel. shutdownDone(ChannelFuture shutdownOutputFuture, ChannelFuture shutdownInputFuture, ChannelPromise promise)
ChannelFuture
AbstractKQueueStreamChannel. shutdownInput(ChannelPromise promise)
private void
AbstractKQueueStreamChannel. shutdownInput0(ChannelPromise promise)
ChannelFuture
AbstractKQueueStreamChannel. shutdownOutput(ChannelPromise promise)
private void
AbstractKQueueStreamChannel. shutdownOutputDone(ChannelFuture shutdownOutputFuture, ChannelPromise promise)
-
Uses of ChannelPromise in io.netty.channel.local
Fields in io.netty.channel.local declared as ChannelPromise Modifier and Type Field Description private ChannelPromise
LocalChannel. connectPromise
Methods in io.netty.channel.local with parameters of type ChannelPromise Modifier and Type Method Description void
LocalChannel.LocalUnsafe. connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
-
Uses of ChannelPromise in io.netty.channel.nio
Fields in io.netty.channel.nio declared as ChannelPromise Modifier and Type Field Description private ChannelPromise
AbstractNioChannel. connectPromise
The future of the current connection attempt.Methods in io.netty.channel.nio with parameters of type ChannelPromise Modifier and Type Method Description void
AbstractNioChannel.AbstractNioUnsafe. connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
private void
AbstractNioChannel.AbstractNioUnsafe. fulfillConnectPromise(ChannelPromise promise, boolean wasActive)
private void
AbstractNioChannel.AbstractNioUnsafe. fulfillConnectPromise(ChannelPromise promise, java.lang.Throwable cause)
-
Uses of ChannelPromise in io.netty.channel.oio
Methods in io.netty.channel.oio with parameters of type ChannelPromise Modifier and Type Method Description void
AbstractOioChannel.DefaultOioUnsafe. connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
-
Uses of ChannelPromise in io.netty.channel.sctp
Methods in io.netty.channel.sctp with parameters of type ChannelPromise Modifier and Type Method Description ChannelFuture
SctpChannel. bindAddress(java.net.InetAddress localAddress, ChannelPromise promise)
Bind a address to the already bound channel to enable multi-homing.ChannelFuture
SctpServerChannel. bindAddress(java.net.InetAddress localAddress, ChannelPromise promise)
Bind a address to the already bound channel to enable multi-homing.ChannelFuture
SctpChannel. unbindAddress(java.net.InetAddress localAddress, ChannelPromise promise)
Unbind the address from channel's multi-homing address list.ChannelFuture
SctpServerChannel. unbindAddress(java.net.InetAddress localAddress, ChannelPromise promise)
Unbind the address from channel's multi-homing address list. -
Uses of ChannelPromise in io.netty.channel.sctp.nio
Methods in io.netty.channel.sctp.nio with parameters of type ChannelPromise Modifier and Type Method Description ChannelFuture
NioSctpChannel. bindAddress(java.net.InetAddress localAddress, ChannelPromise promise)
ChannelFuture
NioSctpServerChannel. bindAddress(java.net.InetAddress localAddress, ChannelPromise promise)
ChannelFuture
NioSctpChannel. unbindAddress(java.net.InetAddress localAddress, ChannelPromise promise)
ChannelFuture
NioSctpServerChannel. unbindAddress(java.net.InetAddress localAddress, ChannelPromise promise)
-
Uses of ChannelPromise in io.netty.channel.sctp.oio
Methods in io.netty.channel.sctp.oio with parameters of type ChannelPromise Modifier and Type Method Description ChannelFuture
OioSctpChannel. bindAddress(java.net.InetAddress localAddress, ChannelPromise promise)
Deprecated.ChannelFuture
OioSctpServerChannel. bindAddress(java.net.InetAddress localAddress, ChannelPromise promise)
Deprecated.ChannelFuture
OioSctpChannel. unbindAddress(java.net.InetAddress localAddress, ChannelPromise promise)
Deprecated.ChannelFuture
OioSctpServerChannel. unbindAddress(java.net.InetAddress localAddress, ChannelPromise promise)
Deprecated. -
Uses of ChannelPromise in io.netty.channel.socket
Methods in io.netty.channel.socket with parameters of type ChannelPromise Modifier and Type Method Description ChannelFuture
DatagramChannel. block(java.net.InetAddress multicastAddress, java.net.InetAddress sourceToBlock, ChannelPromise future)
Block the given sourceToBlock address for the given multicastAddress and notifies theChannelFuture
once the operation completes.ChannelFuture
DatagramChannel. block(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress sourceToBlock, ChannelPromise future)
Block the given sourceToBlock address for the given multicastAddress on the given networkInterface and notifies theChannelFuture
once the operation completes.ChannelFuture
DatagramChannel. joinGroup(java.net.InetAddress multicastAddress, ChannelPromise future)
Joins a multicast group and notifies theChannelFuture
once the operation completes.ChannelFuture
DatagramChannel. joinGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source, ChannelPromise future)
Joins the specified multicast group at the specified interface and notifies theChannelFuture
once the operation completes.ChannelFuture
DatagramChannel. joinGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface, ChannelPromise future)
Joins the specified multicast group at the specified interface and notifies theChannelFuture
once the operation completes.ChannelFuture
DatagramChannel. leaveGroup(java.net.InetAddress multicastAddress, ChannelPromise future)
Leaves a multicast group and notifies theChannelFuture
once the operation completes.ChannelFuture
DatagramChannel. leaveGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source, ChannelPromise future)
Leave the specified multicast group at the specified interface using the specified source and notifies theChannelFuture
once the operation completes.ChannelFuture
DatagramChannel. leaveGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface, ChannelPromise future)
Leaves a multicast group on a specified local interface and notifies theChannelFuture
once the operation completes.ChannelFuture
DuplexChannel. shutdown(ChannelPromise promise)
Will shutdown the input and output sides of this channel.ChannelFuture
DuplexChannel. shutdownInput(ChannelPromise promise)
Will shutdown the input and notifyChannelPromise
.ChannelFuture
DuplexChannel. shutdownOutput(ChannelPromise promise)
Will shutdown the output and notifyChannelPromise
. -
Uses of ChannelPromise in io.netty.channel.socket.nio
Methods in io.netty.channel.socket.nio with parameters of type ChannelPromise Modifier and Type Method Description ChannelFuture
NioDatagramChannel. block(java.net.InetAddress multicastAddress, java.net.InetAddress sourceToBlock, ChannelPromise promise)
Block the given sourceToBlock address for the given multicastAddressChannelFuture
NioDatagramChannel. block(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress sourceToBlock, ChannelPromise promise)
Block the given sourceToBlock address for the given multicastAddress on the given networkInterfaceChannelFuture
NioDatagramChannel. joinGroup(java.net.InetAddress multicastAddress, ChannelPromise promise)
ChannelFuture
NioDatagramChannel. joinGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source, ChannelPromise promise)
ChannelFuture
NioDatagramChannel. joinGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface, ChannelPromise promise)
ChannelFuture
NioDatagramChannel. leaveGroup(java.net.InetAddress multicastAddress, ChannelPromise promise)
ChannelFuture
NioDatagramChannel. leaveGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source, ChannelPromise promise)
ChannelFuture
NioDatagramChannel. leaveGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface, ChannelPromise promise)
ChannelFuture
NioDomainSocketChannel. shutdown(ChannelPromise promise)
ChannelFuture
NioSocketChannel. shutdown(ChannelPromise promise)
private static void
NioDomainSocketChannel. shutdownDone(ChannelFuture shutdownOutputFuture, ChannelFuture shutdownInputFuture, ChannelPromise promise)
private static void
NioSocketChannel. shutdownDone(ChannelFuture shutdownOutputFuture, ChannelFuture shutdownInputFuture, ChannelPromise promise)
ChannelFuture
NioDomainSocketChannel. shutdownInput(ChannelPromise promise)
ChannelFuture
NioSocketChannel. shutdownInput(ChannelPromise promise)
private void
NioDomainSocketChannel. shutdownInput0(ChannelPromise promise)
private void
NioSocketChannel. shutdownInput0(ChannelPromise promise)
ChannelFuture
NioDomainSocketChannel. shutdownOutput(ChannelPromise promise)
ChannelFuture
NioSocketChannel. shutdownOutput(ChannelPromise promise)
private void
NioDomainSocketChannel. shutdownOutputDone(ChannelFuture shutdownOutputFuture, ChannelPromise promise)
private void
NioSocketChannel. shutdownOutputDone(ChannelFuture shutdownOutputFuture, ChannelPromise promise)
-
Uses of ChannelPromise in io.netty.channel.socket.oio
Methods in io.netty.channel.socket.oio with parameters of type ChannelPromise Modifier and Type Method Description ChannelFuture
OioDatagramChannel. block(java.net.InetAddress multicastAddress, java.net.InetAddress sourceToBlock, ChannelPromise promise)
Deprecated.ChannelFuture
OioDatagramChannel. block(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress sourceToBlock, ChannelPromise promise)
Deprecated.ChannelFuture
OioDatagramChannel. joinGroup(java.net.InetAddress multicastAddress, ChannelPromise promise)
Deprecated.ChannelFuture
OioDatagramChannel. joinGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source, ChannelPromise promise)
Deprecated.ChannelFuture
OioDatagramChannel. joinGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface, ChannelPromise promise)
Deprecated.ChannelFuture
OioDatagramChannel. leaveGroup(java.net.InetAddress multicastAddress, ChannelPromise promise)
Deprecated.ChannelFuture
OioDatagramChannel. leaveGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source, ChannelPromise promise)
Deprecated.ChannelFuture
OioDatagramChannel. leaveGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface, ChannelPromise promise)
Deprecated.ChannelFuture
OioSocketChannel. shutdown(ChannelPromise promise)
Deprecated.private static void
OioSocketChannel. shutdownDone(ChannelFuture shutdownOutputFuture, ChannelFuture shutdownInputFuture, ChannelPromise promise)
Deprecated.ChannelFuture
OioSocketChannel. shutdownInput(ChannelPromise promise)
Deprecated.private void
OioSocketChannel. shutdownInput0(ChannelPromise promise)
Deprecated.ChannelFuture
OioSocketChannel. shutdownOutput(ChannelPromise promise)
Deprecated.private void
OioSocketChannel. shutdownOutput0(ChannelPromise promise)
Deprecated.private void
OioSocketChannel. shutdownOutputDone(ChannelFuture shutdownOutputFuture, ChannelPromise promise)
Deprecated. -
Uses of ChannelPromise in io.netty.handler.address
Methods in io.netty.handler.address with parameters of type ChannelPromise Modifier and Type Method Description void
DynamicAddressConnectHandler. connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
void
ResolveAddressHandler. connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
-
Uses of ChannelPromise in io.netty.handler.codec
Methods in io.netty.handler.codec with parameters of type ChannelPromise Modifier and Type Method Description void
DatagramPacketEncoder. bind(ChannelHandlerContext ctx, java.net.SocketAddress localAddress, ChannelPromise promise)
void
DatagramPacketEncoder. close(ChannelHandlerContext ctx, ChannelPromise promise)
void
DatagramPacketEncoder. connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
void
DatagramPacketEncoder. deregister(ChannelHandlerContext ctx, ChannelPromise promise)
void
DatagramPacketEncoder. disconnect(ChannelHandlerContext ctx, ChannelPromise promise)
void
ByteToMessageCodec. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)
void
MessageToByteEncoder. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)
void
MessageToMessageCodec. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)
void
MessageToMessageEncoder. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)
private static void
MessageToMessageEncoder. writePromiseCombiner(ChannelHandlerContext ctx, CodecOutputList out, ChannelPromise promise)
-
Uses of ChannelPromise in io.netty.handler.codec.compression
Methods in io.netty.handler.codec.compression with parameters of type ChannelPromise Modifier and Type Method Description void
Bzip2Encoder. close(ChannelHandlerContext ctx, ChannelPromise promise)
ChannelFuture
Bzip2Encoder. close(ChannelPromise promise)
Close thisBzip2Encoder
and so finish the encoding.void
JdkZlibEncoder. close(ChannelHandlerContext ctx, ChannelPromise promise)
ChannelFuture
JdkZlibEncoder. close(ChannelPromise promise)
void
JZlibEncoder. close(ChannelHandlerContext ctx, ChannelPromise promise)
ChannelFuture
JZlibEncoder. close(ChannelPromise promise)
abstract ChannelFuture
ZlibEncoder. close(ChannelPromise promise)
Close thisZlibEncoder
and so finish the encoding.(package private) static void
EncoderUtil. closeAfterFinishEncode(ChannelHandlerContext ctx, ChannelFuture finishFuture, ChannelPromise promise)
private ChannelFuture
Bzip2Encoder. finishEncode(ChannelHandlerContext ctx, ChannelPromise promise)
private ChannelFuture
JdkZlibEncoder. finishEncode(ChannelHandlerContext ctx, ChannelPromise promise)
private ChannelFuture
JZlibEncoder. finishEncode(ChannelHandlerContext ctx, ChannelPromise promise)
-
Uses of ChannelPromise in io.netty.handler.codec.http
Methods in io.netty.handler.codec.http with parameters of type ChannelPromise Modifier and Type Method Description void
HttpClientUpgradeHandler. bind(ChannelHandlerContext ctx, java.net.SocketAddress localAddress, ChannelPromise promise)
void
HttpClientUpgradeHandler. close(ChannelHandlerContext ctx, ChannelPromise promise)
void
HttpClientUpgradeHandler. connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
void
HttpClientUpgradeHandler. deregister(ChannelHandlerContext ctx, ChannelPromise promise)
void
HttpClientUpgradeHandler. disconnect(ChannelHandlerContext ctx, ChannelPromise promise)
void
HttpClientUpgradeHandler. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)
void
HttpObjectEncoder. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)
void
HttpServerKeepAliveHandler. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)
private static void
HttpObjectEncoder. writeOutList(ChannelHandlerContext ctx, java.util.List<java.lang.Object> out, ChannelPromise promise)
private static void
HttpObjectEncoder. writePromiseCombiner(ChannelHandlerContext ctx, java.util.List<java.lang.Object> out, ChannelPromise promise)
-
Uses of ChannelPromise in io.netty.handler.codec.http.cors
Methods in io.netty.handler.codec.http.cors with parameters of type ChannelPromise Modifier and Type Method Description void
CorsHandler. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)
-
Uses of ChannelPromise in io.netty.handler.codec.http.websocketx
Fields in io.netty.handler.codec.http.websocketx declared as ChannelPromise Modifier and Type Field Description private ChannelPromise
WebSocketProtocolHandler. closeSent
private ChannelPromise
WebSocketClientProtocolHandshakeHandler. handshakePromise
private ChannelPromise
WebSocketServerProtocolHandshakeHandler. handshakePromise
Methods in io.netty.handler.codec.http.websocketx with parameters of type ChannelPromise Modifier and Type Method Description void
WebSocketProtocolHandler. bind(ChannelHandlerContext ctx, java.net.SocketAddress localAddress, ChannelPromise promise)
ChannelFuture
WebSocketClientHandshaker. close(ChannelHandlerContext ctx, CloseWebSocketFrame frame, ChannelPromise promise)
Performs the closing handshakeChannelFuture
WebSocketClientHandshaker. close(Channel channel, CloseWebSocketFrame frame, ChannelPromise promise)
Performs the closing handshake When called from within aChannelHandler
you most likely want to useWebSocketClientHandshaker.close(ChannelHandlerContext, CloseWebSocketFrame, ChannelPromise)
.void
WebSocketProtocolHandler. close(ChannelHandlerContext ctx, ChannelPromise promise)
ChannelFuture
WebSocketServerHandshaker. close(ChannelHandlerContext ctx, CloseWebSocketFrame frame, ChannelPromise promise)
Performs the closing handshake.ChannelFuture
WebSocketServerHandshaker. close(Channel channel, CloseWebSocketFrame frame, ChannelPromise promise)
Performs the closing handshake.ChannelFuture
WebSocketServerHandshaker00. close(ChannelHandlerContext ctx, CloseWebSocketFrame frame, ChannelPromise promise)
Echo back the closing frameChannelFuture
WebSocketServerHandshaker00. close(Channel channel, CloseWebSocketFrame frame, ChannelPromise promise)
Echo back the closing frameprivate ChannelFuture
WebSocketClientHandshaker. close0(ChannelOutboundInvoker invoker, Channel channel, CloseWebSocketFrame frame, ChannelPromise promise)
private ChannelFuture
WebSocketServerHandshaker. close0(ChannelOutboundInvoker invoker, CloseWebSocketFrame frame, ChannelPromise promise)
(package private) void
WebSocketProtocolHandler. closeSent(ChannelPromise promise)
void
WebSocketProtocolHandler. connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
void
WebSocketProtocolHandler. deregister(ChannelHandlerContext ctx, ChannelPromise promise)
void
WebSocketProtocolHandler. disconnect(ChannelHandlerContext ctx, ChannelPromise promise)
ChannelFuture
WebSocketClientHandshaker. handshake(Channel channel, ChannelPromise promise)
Begins the opening handshakeChannelFuture
WebSocketServerHandshaker. handshake(Channel channel, FullHttpRequest req, HttpHeaders responseHeaders, ChannelPromise promise)
Performs the opening handshake When call this method you MUST NOT retain theFullHttpRequest
which is passed in.ChannelFuture
WebSocketServerHandshaker. handshake(Channel channel, HttpRequest req, HttpHeaders responseHeaders, ChannelPromise promise)
Performs the opening handshake When call this method you MUST NOT retain theHttpRequest
which is passed in.ChannelFuture
WebSocketClientHandshaker. processHandshake(Channel channel, HttpResponse response, ChannelPromise promise)
Process the opening handshake initiated byWebSocketClientHandshaker.handshake(io.netty.channel.Channel)
}.static ChannelFuture
WebSocketServerHandshakerFactory. sendUnsupportedVersionResponse(Channel channel, ChannelPromise promise)
Return that we need cannot support the web socket versionvoid
WebSocketProtocolHandler. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)
-
Uses of ChannelPromise in io.netty.handler.codec.http.websocketx.extensions
Methods in io.netty.handler.codec.http.websocketx.extensions with parameters of type ChannelPromise Modifier and Type Method Description private void
WebSocketServerExtensionHandler. handlePotentialUpgrade(ChannelHandlerContext ctx, ChannelPromise promise, HttpResponse httpResponse, java.util.List<WebSocketServerExtension> validExtensionsList)
protected void
WebSocketServerExtensionHandler. onHttpResponseWrite(ChannelHandlerContext ctx, HttpResponse response, ChannelPromise promise)
This is a method exposed to perform fail-fast checks of user-defined http types.void
WebSocketClientExtensionHandler. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)
void
WebSocketServerExtensionHandler. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)
-
Uses of ChannelPromise in io.netty.handler.codec.http2
Classes in io.netty.handler.codec.http2 that implement ChannelPromise 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 ChannelPromise Modifier and Type Field Description private ChannelPromise
AbstractHttp2StreamChannel. closePromise
protected ChannelPromise
DefaultHttp2ConnectionEncoder.FlowControlledBase. promise
private ChannelPromise
Http2CodecUtil.SimpleChannelPromiseAggregator. promise
private ChannelPromise
Http2ConnectionHandler.ClosingChannelFutureListener. promise
(package private) ChannelPromise
StreamBufferingEncoder.Frame. promise
Methods in io.netty.handler.codec.http2 that return ChannelPromise Modifier and Type Method Description ChannelPromise
Http2CodecUtil.SimpleChannelPromiseAggregator. doneAllocatingPromises()
Signify that no moreHttp2CodecUtil.SimpleChannelPromiseAggregator.newPromise()
allocations will be made.private ChannelPromise
Http2ControlFrameLimitEncoder. handleOutstandingControlFrames(ChannelHandlerContext ctx, ChannelPromise promise)
ChannelPromise
AbstractHttp2StreamChannel. newPromise()
ChannelPromise
Http2CodecUtil.SimpleChannelPromiseAggregator. newPromise()
Allocate a new promise which will be used to aggregate the overall success of this promise aggregator.ChannelPromise
Http2CodecUtil.SimpleChannelPromiseAggregator. setFailure(java.lang.Throwable cause)
Fail this object if it has not already been failed.private ChannelPromise
Http2CodecUtil.SimpleChannelPromiseAggregator. setPromise()
ChannelPromise
Http2CodecUtil.SimpleChannelPromiseAggregator. setSuccess(java.lang.Void result)
ChannelPromise
AbstractHttp2StreamChannel.Http2ChannelUnsafe. voidPromise()
ChannelPromise
AbstractHttp2StreamChannel. voidPromise()
Methods in io.netty.handler.codec.http2 with parameters of type ChannelPromise Modifier and Type Method Description ChannelFuture
AbstractHttp2StreamChannel. bind(java.net.SocketAddress localAddress, ChannelPromise promise)
void
AbstractHttp2StreamChannel.Http2ChannelUnsafe. bind(java.net.SocketAddress localAddress, ChannelPromise promise)
void
Http2ConnectionHandler. bind(ChannelHandlerContext ctx, java.net.SocketAddress localAddress, ChannelPromise promise)
ChannelFuture
AbstractHttp2StreamChannel. close(ChannelPromise promise)
void
AbstractHttp2StreamChannel.Http2ChannelUnsafe. close(ChannelPromise promise)
(package private) void
AbstractHttp2StreamChannel.Http2ChannelUnsafe. close(ChannelPromise promise, Http2Error error)
void
Http2ConnectionHandler. close(ChannelHandlerContext ctx, ChannelPromise promise)
ChannelFuture
AbstractHttp2StreamChannel. connect(java.net.SocketAddress remoteAddress, ChannelPromise promise)
ChannelFuture
AbstractHttp2StreamChannel. connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
void
AbstractHttp2StreamChannel.Http2ChannelUnsafe. connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
void
Http2ConnectionHandler. connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
ChannelFuture
AbstractHttp2StreamChannel. deregister(ChannelPromise promise)
void
AbstractHttp2StreamChannel.Http2ChannelUnsafe. deregister(ChannelPromise promise)
void
Http2ConnectionHandler. deregister(ChannelHandlerContext ctx, ChannelPromise promise)
ChannelFuture
AbstractHttp2StreamChannel. disconnect(ChannelPromise promise)
void
AbstractHttp2StreamChannel.Http2ChannelUnsafe. disconnect(ChannelPromise promise)
void
Http2ConnectionHandler. disconnect(ChannelHandlerContext ctx, ChannelPromise promise)
private void
Http2ConnectionHandler. doGracefulShutdown(ChannelHandlerContext ctx, ChannelFuture future, ChannelPromise promise)
private void
AbstractHttp2StreamChannel.Http2ChannelUnsafe. fireChannelInactiveAndDeregister(ChannelPromise promise, boolean fireChannelInactive)
private void
AbstractHttp2StreamChannel.Http2ChannelUnsafe. firstWriteComplete(ChannelFuture future, ChannelPromise promise)
ChannelFuture
Http2ConnectionHandler. goAway(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData, ChannelPromise promise)
private ChannelFuture
Http2ConnectionHandler. goAway(ChannelHandlerContext ctx, Http2Exception cause, ChannelPromise promise)
Close the remote endpoint with aGO_AWAY
frame.ChannelFuture
Http2LifecycleManager. goAway(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData, ChannelPromise promise)
Prevents the peer from creating streams and close the connection iferrorCode
is notHttp2Error.NO_ERROR
.private ChannelPromise
Http2ControlFrameLimitEncoder. handleOutstandingControlFrames(ChannelHandlerContext ctx, ChannelPromise promise)
private boolean
Http2FrameCodec. initializeNewStream(ChannelHandlerContext ctx, Http2FrameCodec.DefaultHttp2FrameStream http2FrameStream, ChannelPromise promise)
private ChannelFutureListener
Http2ConnectionHandler. newClosingChannelFutureListener(ChannelHandlerContext ctx, ChannelPromise promise)
void
AbstractHttp2StreamChannel.Http2ChannelUnsafe. register(EventLoop eventLoop, ChannelPromise promise)
ChannelFuture
Http2ConnectionHandler. resetStream(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise)
private ChannelFuture
Http2ConnectionHandler. resetStream(ChannelHandlerContext ctx, Http2Stream stream, long errorCode, ChannelPromise promise)
ChannelFuture
Http2LifecycleManager. resetStream(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise)
Ensure the stream identified bystreamId
is reset.private ChannelFuture
Http2ConnectionHandler. resetUnknownStream(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise)
Sends aRST_STREAM
frame even if we don't know about the stream.private void
AbstractHttp2StreamChannel.Http2ChannelUnsafe. safeSetSuccess(ChannelPromise promise)
private static ChannelFuture
DefaultHttp2ConnectionEncoder. sendHeaders(Http2FrameWriter frameWriter, ChannelHandlerContext ctx, int streamId, Http2Headers headers, boolean hasPriority, int streamDependency, short weight, boolean exclusive, int padding, boolean endOfStream, ChannelPromise promise)
Write headers viaHttp2FrameWriter
.void
AbstractHttp2StreamChannel.Http2ChannelUnsafe. write(java.lang.Object msg, ChannelPromise promise)
ChannelFuture
AbstractHttp2StreamChannel. write(java.lang.Object msg, ChannelPromise promise)
void
Http2ConnectionHandler. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)
void
Http2FrameCodec. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)
Processes allHttp2Frame
s.void
HttpToHttp2ConnectionHandler. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)
Handles conversion ofHttpMessage
andHttpContent
to HTTP/2 frames.ChannelFuture
AbstractHttp2StreamChannel. writeAndFlush(java.lang.Object msg, ChannelPromise promise)
private void
AbstractHttp2StreamChannel.Http2ChannelUnsafe. writeComplete(ChannelFuture future, ChannelPromise promise)
ChannelFuture
CompressorHttp2ConnectionEncoder. writeData(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endOfStream, ChannelPromise promise)
ChannelFuture
DecoratingHttp2FrameWriter. writeData(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endStream, ChannelPromise promise)
ChannelFuture
DefaultHttp2ConnectionEncoder. writeData(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endOfStream, ChannelPromise promise)
ChannelFuture
DefaultHttp2FrameWriter. writeData(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endStream, ChannelPromise promise)
ChannelFuture
Http2DataWriter. writeData(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endStream, ChannelPromise promise)
Writes aDATA
frame to the remote endpoint.ChannelFuture
Http2OutboundFrameLogger. writeData(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endStream, ChannelPromise promise)
ChannelFuture
StreamBufferingEncoder. writeData(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endOfStream, ChannelPromise promise)
ChannelFuture
DecoratingHttp2FrameWriter. writeFrame(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf payload, ChannelPromise promise)
ChannelFuture
DefaultHttp2ConnectionEncoder. writeFrame(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf payload, ChannelPromise promise)
ChannelFuture
DefaultHttp2FrameWriter. writeFrame(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf payload, ChannelPromise promise)
ChannelFuture
Http2ConnectionEncoder. writeFrame(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf payload, ChannelPromise promise)
Writes the given data to the internalHttp2FrameWriter
without performing any state checks on the connection/stream.ChannelFuture
Http2FrameWriter. writeFrame(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf payload, ChannelPromise promise)
Generic write method for any HTTP/2 frame.ChannelFuture
Http2OutboundFrameLogger. writeFrame(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf payload, ChannelPromise promise)
ChannelFuture
DecoratingHttp2FrameWriter. writeGoAway(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData, ChannelPromise promise)
ChannelFuture
DefaultHttp2ConnectionEncoder. writeGoAway(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData, ChannelPromise promise)
ChannelFuture
DefaultHttp2FrameWriter. writeGoAway(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData, ChannelPromise promise)
ChannelFuture
Http2FrameWriter. writeGoAway(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData, ChannelPromise promise)
Writes a GO_AWAY frame to the remote endpoint.ChannelFuture
Http2OutboundFrameLogger. writeGoAway(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData, ChannelPromise promise)
private void
Http2FrameCodec. writeGoAwayFrame(ChannelHandlerContext ctx, Http2GoAwayFrame frame, ChannelPromise promise)
ChannelFuture
CompressorHttp2ConnectionEncoder. writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream, ChannelPromise promise)
ChannelFuture
CompressorHttp2ConnectionEncoder. writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endOfStream, ChannelPromise promise)
ChannelFuture
DecoratingHttp2FrameWriter. writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream, ChannelPromise promise)
ChannelFuture
DecoratingHttp2FrameWriter. writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endStream, ChannelPromise promise)
ChannelFuture
DefaultHttp2ConnectionEncoder. writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream, ChannelPromise promise)
ChannelFuture
DefaultHttp2ConnectionEncoder. writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endOfStream, ChannelPromise promise)
ChannelFuture
DefaultHttp2FrameWriter. writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream, ChannelPromise promise)
ChannelFuture
DefaultHttp2FrameWriter. writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endStream, ChannelPromise promise)
ChannelFuture
Http2FrameWriter. writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream, ChannelPromise promise)
Writes a HEADERS frame to the remote endpoint.ChannelFuture
Http2FrameWriter. writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endStream, ChannelPromise promise)
Writes a HEADERS frame with priority specified to the remote endpoint.ChannelFuture
Http2OutboundFrameLogger. writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream, ChannelPromise promise)
ChannelFuture
Http2OutboundFrameLogger. writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endStream, ChannelPromise promise)
ChannelFuture
StreamBufferingEncoder. writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream, ChannelPromise promise)
ChannelFuture
StreamBufferingEncoder. writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endOfStream, ChannelPromise promise)
private ChannelFuture
DefaultHttp2ConnectionEncoder. writeHeaders0(ChannelHandlerContext ctx, int streamId, Http2Headers headers, boolean hasPriority, int streamDependency, short weight, boolean exclusive, int padding, boolean endOfStream, ChannelPromise promise)
private ChannelFuture
StreamBufferingEncoder. writeHeaders0(ChannelHandlerContext ctx, int streamId, Http2Headers headers, boolean hasPriority, int streamDependency, short weight, boolean exclusive, int padding, boolean endOfStream, ChannelPromise promise)
private void
Http2FrameCodec. writeHeadersFrame(ChannelHandlerContext ctx, Http2HeadersFrame headersFrame, ChannelPromise promise)
private ChannelFuture
DefaultHttp2FrameWriter. writeHeadersInternal(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream, boolean hasPriority, int streamDependency, short weight, boolean exclusive, ChannelPromise promise)
private void
AbstractHttp2StreamChannel.Http2ChannelUnsafe. writeHttp2StreamFrame(Http2StreamFrame frame, ChannelPromise promise)
ChannelFuture
DecoratingHttp2FrameWriter. writePing(ChannelHandlerContext ctx, boolean ack, long data, ChannelPromise promise)
ChannelFuture
DefaultHttp2ConnectionEncoder. writePing(ChannelHandlerContext ctx, boolean ack, long data, ChannelPromise promise)
ChannelFuture
DefaultHttp2FrameWriter. writePing(ChannelHandlerContext ctx, boolean ack, long data, ChannelPromise promise)
ChannelFuture
Http2ControlFrameLimitEncoder. writePing(ChannelHandlerContext ctx, boolean ack, long data, ChannelPromise promise)
ChannelFuture
Http2FrameWriter. writePing(ChannelHandlerContext ctx, boolean ack, long data, ChannelPromise promise)
Writes a PING frame to the remote endpoint.ChannelFuture
Http2OutboundFrameLogger. writePing(ChannelHandlerContext ctx, boolean ack, long data, ChannelPromise promise)
ChannelFuture
DecoratingHttp2FrameWriter. writePriority(ChannelHandlerContext ctx, int streamId, int streamDependency, short weight, boolean exclusive, ChannelPromise promise)
ChannelFuture
DefaultHttp2ConnectionEncoder. writePriority(ChannelHandlerContext ctx, int streamId, int streamDependency, short weight, boolean exclusive, ChannelPromise promise)
ChannelFuture
DefaultHttp2FrameWriter. writePriority(ChannelHandlerContext ctx, int streamId, int streamDependency, short weight, boolean exclusive, ChannelPromise promise)
ChannelFuture
Http2FrameWriter. writePriority(ChannelHandlerContext ctx, int streamId, int streamDependency, short weight, boolean exclusive, ChannelPromise promise)
Writes a PRIORITY frame to the remote endpoint.ChannelFuture
Http2OutboundFrameLogger. writePriority(ChannelHandlerContext ctx, int streamId, int streamDependency, short weight, boolean exclusive, ChannelPromise promise)
ChannelFuture
DecoratingHttp2FrameWriter. writePushPromise(ChannelHandlerContext ctx, int streamId, int promisedStreamId, Http2Headers headers, int padding, ChannelPromise promise)
ChannelFuture
DefaultHttp2ConnectionEncoder. writePushPromise(ChannelHandlerContext ctx, int streamId, int promisedStreamId, Http2Headers headers, int padding, ChannelPromise promise)
ChannelFuture
DefaultHttp2FrameWriter. writePushPromise(ChannelHandlerContext ctx, int streamId, int promisedStreamId, Http2Headers headers, int padding, ChannelPromise promise)
private void
Http2FrameCodec. writePushPromise(ChannelHandlerContext ctx, Http2PushPromiseFrame pushPromiseFrame, ChannelPromise promise)
ChannelFuture
Http2FrameWriter. writePushPromise(ChannelHandlerContext ctx, int streamId, int promisedStreamId, Http2Headers headers, int padding, ChannelPromise promise)
Writes a PUSH_PROMISE frame to the remote endpoint.ChannelFuture
Http2OutboundFrameLogger. writePushPromise(ChannelHandlerContext ctx, int streamId, int promisedStreamId, Http2Headers headers, int padding, ChannelPromise promise)
ChannelFuture
DecoratingHttp2FrameWriter. writeRstStream(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise)
ChannelFuture
DefaultHttp2ConnectionEncoder. writeRstStream(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise)
ChannelFuture
DefaultHttp2FrameWriter. writeRstStream(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise)
ChannelFuture
Http2ControlFrameLimitEncoder. writeRstStream(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise)
ChannelFuture
Http2FrameWriter. writeRstStream(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise)
Writes a RST_STREAM frame to the remote endpoint.ChannelFuture
Http2OutboundFrameLogger. writeRstStream(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise)
ChannelFuture
StreamBufferingEncoder. writeRstStream(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise)
ChannelFuture
DecoratingHttp2FrameWriter. writeSettings(ChannelHandlerContext ctx, Http2Settings settings, ChannelPromise promise)
ChannelFuture
DefaultHttp2ConnectionEncoder. writeSettings(ChannelHandlerContext ctx, Http2Settings settings, ChannelPromise promise)
ChannelFuture
DefaultHttp2FrameWriter. writeSettings(ChannelHandlerContext ctx, Http2Settings settings, ChannelPromise promise)
ChannelFuture
Http2FrameWriter. writeSettings(ChannelHandlerContext ctx, Http2Settings settings, ChannelPromise promise)
Writes a SETTINGS frame to the remote endpoint.ChannelFuture
Http2OutboundFrameLogger. writeSettings(ChannelHandlerContext ctx, Http2Settings settings, ChannelPromise promise)
ChannelFuture
DecoratingHttp2FrameWriter. writeSettingsAck(ChannelHandlerContext ctx, ChannelPromise promise)
ChannelFuture
DefaultHttp2ConnectionEncoder. writeSettingsAck(ChannelHandlerContext ctx, ChannelPromise promise)
ChannelFuture
DefaultHttp2FrameWriter. writeSettingsAck(ChannelHandlerContext ctx, ChannelPromise promise)
ChannelFuture
Http2ControlFrameLimitEncoder. writeSettingsAck(ChannelHandlerContext ctx, ChannelPromise promise)
ChannelFuture
Http2FrameWriter. writeSettingsAck(ChannelHandlerContext ctx, ChannelPromise promise)
Writes a SETTINGS acknowledgment to the remote endpoint.ChannelFuture
Http2OutboundFrameLogger. writeSettingsAck(ChannelHandlerContext ctx, ChannelPromise promise)
ChannelFuture
StreamBufferingEncoder. writeSettingsAck(ChannelHandlerContext ctx, ChannelPromise promise)
ChannelFuture
DecoratingHttp2FrameWriter. writeWindowUpdate(ChannelHandlerContext ctx, int streamId, int windowSizeIncrement, ChannelPromise promise)
ChannelFuture
DefaultHttp2ConnectionEncoder. writeWindowUpdate(ChannelHandlerContext ctx, int streamId, int windowSizeIncrement, ChannelPromise promise)
ChannelFuture
DefaultHttp2FrameWriter. writeWindowUpdate(ChannelHandlerContext ctx, int streamId, int windowSizeIncrement, ChannelPromise promise)
ChannelFuture
Http2FrameWriter. writeWindowUpdate(ChannelHandlerContext ctx, int streamId, int windowSizeIncrement, ChannelPromise promise)
Writes a WINDOW_UPDATE frame to the remote endpoint.ChannelFuture
Http2OutboundFrameLogger. writeWindowUpdate(ChannelHandlerContext ctx, int streamId, int windowSizeIncrement, ChannelPromise promise)
Constructors in io.netty.handler.codec.http2 with parameters of type ChannelPromise Constructor Description ClosingChannelFutureListener(ChannelHandlerContext ctx, ChannelPromise promise)
ClosingChannelFutureListener(ChannelHandlerContext ctx, ChannelPromise promise, long timeout, java.util.concurrent.TimeUnit unit)
DataFrame(ByteBuf data, int padding, boolean endOfStream, ChannelPromise promise)
FlowControlledBase(Http2Stream stream, int padding, boolean endOfStream, ChannelPromise promise)
FlowControlledData(Http2Stream stream, ByteBuf buf, int padding, boolean endOfStream, ChannelPromise promise)
FlowControlledHeaders(Http2Stream stream, Http2Headers headers, boolean hasPriority, int streamDependency, short weight, boolean exclusive, int padding, boolean endOfStream, ChannelPromise promise)
Frame(ChannelPromise promise)
HeadersFrame(Http2Headers headers, boolean hasPriority, int streamDependency, short weight, boolean exclusive, int padding, boolean endOfStream, ChannelPromise promise)
SimpleChannelPromiseAggregator(ChannelPromise promise, Channel c, EventExecutor e)
-
Uses of ChannelPromise in io.netty.handler.codec.spdy
Fields in io.netty.handler.codec.spdy declared as ChannelPromise Modifier and Type Field Description (package private) ChannelPromise
SpdySession.PendingWrite. promise
private ChannelPromise
SpdySessionHandler.ClosingChannelFutureListener. promise
Methods in io.netty.handler.codec.spdy with parameters of type ChannelPromise Modifier and Type Method Description void
SpdyFrameCodec. bind(ChannelHandlerContext ctx, java.net.SocketAddress localAddress, ChannelPromise promise)
void
SpdyFrameCodec. close(ChannelHandlerContext ctx, ChannelPromise promise)
void
SpdySessionHandler. close(ChannelHandlerContext ctx, ChannelPromise promise)
void
SpdyFrameCodec. connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
void
SpdyFrameCodec. deregister(ChannelHandlerContext ctx, ChannelPromise promise)
void
SpdyFrameCodec. disconnect(ChannelHandlerContext ctx, ChannelPromise promise)
private void
SpdySessionHandler. handleOutboundMessage(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)
private void
SpdySessionHandler. sendGoAwayFrame(ChannelHandlerContext ctx, ChannelPromise future)
void
SpdyFrameCodec. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)
void
SpdySessionHandler. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)
Constructors in io.netty.handler.codec.spdy with parameters of type ChannelPromise Constructor Description ClosingChannelFutureListener(ChannelHandlerContext ctx, ChannelPromise promise)
PendingWrite(SpdyDataFrame spdyDataFrame, ChannelPromise promise)
-
Uses of ChannelPromise in io.netty.handler.flush
Methods in io.netty.handler.flush with parameters of type ChannelPromise Modifier and Type Method Description void
FlushConsolidationHandler. close(ChannelHandlerContext ctx, ChannelPromise promise)
void
FlushConsolidationHandler. disconnect(ChannelHandlerContext ctx, ChannelPromise promise)
-
Uses of ChannelPromise in io.netty.handler.logging
Methods in io.netty.handler.logging with parameters of type ChannelPromise Modifier and Type Method Description void
LoggingHandler. bind(ChannelHandlerContext ctx, java.net.SocketAddress localAddress, ChannelPromise promise)
void
LoggingHandler. close(ChannelHandlerContext ctx, ChannelPromise promise)
void
LoggingHandler. connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
void
LoggingHandler. deregister(ChannelHandlerContext ctx, ChannelPromise promise)
void
LoggingHandler. disconnect(ChannelHandlerContext ctx, ChannelPromise promise)
void
LoggingHandler. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)
-
Uses of ChannelPromise in io.netty.handler.pcap
Methods in io.netty.handler.pcap with parameters of type ChannelPromise Modifier and Type Method Description void
PcapWriteHandler. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)
-
Uses of ChannelPromise in io.netty.handler.proxy
Methods in io.netty.handler.proxy with parameters of type ChannelPromise Modifier and Type Method Description private void
ProxyHandler. addPendingWrite(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)
void
HttpProxyHandler.HttpClientCodecWrapper. bind(ChannelHandlerContext ctx, java.net.SocketAddress localAddress, ChannelPromise promise)
void
HttpProxyHandler.HttpClientCodecWrapper. close(ChannelHandlerContext ctx, ChannelPromise promise)
void
HttpProxyHandler.HttpClientCodecWrapper. connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
void
ProxyHandler. connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
void
HttpProxyHandler.HttpClientCodecWrapper. deregister(ChannelHandlerContext ctx, ChannelPromise promise)
void
HttpProxyHandler.HttpClientCodecWrapper. disconnect(ChannelHandlerContext ctx, ChannelPromise promise)
void
HttpProxyHandler.HttpClientCodecWrapper. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)
void
ProxyHandler. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)
-
Uses of ChannelPromise in io.netty.handler.ssl
Methods in io.netty.handler.ssl with parameters of type ChannelPromise Modifier and Type Method Description private static void
SslHandler. addCloseListener(ChannelFuture future, ChannelPromise promise)
void
SslClientHelloHandler. bind(ChannelHandlerContext ctx, java.net.SocketAddress localAddress, ChannelPromise promise)
void
SslHandler. bind(ChannelHandlerContext ctx, java.net.SocketAddress localAddress, ChannelPromise promise)
void
SslClientHelloHandler. close(ChannelHandlerContext ctx, ChannelPromise promise)
void
SslHandler. close(ChannelHandlerContext ctx, ChannelPromise promise)
ChannelFuture
SslHandler. close(ChannelPromise promise)
Deprecated.ChannelFuture
SslHandler. closeOutbound(ChannelPromise promise)
Sends an SSLclose_notify
message to the specified channel and destroys the underlyingSSLEngine
.private void
SslHandler. closeOutbound0(ChannelPromise promise)
private void
SslHandler. closeOutboundAndChannel(ChannelHandlerContext ctx, ChannelPromise promise, boolean disconnect)
void
SslClientHelloHandler. connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
void
SslHandler. connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
void
SslClientHelloHandler. deregister(ChannelHandlerContext ctx, ChannelPromise promise)
void
SslHandler. deregister(ChannelHandlerContext ctx, ChannelPromise promise)
void
SslClientHelloHandler. disconnect(ChannelHandlerContext ctx, ChannelPromise promise)
void
SslHandler. disconnect(ChannelHandlerContext ctx, ChannelPromise promise)
private void
SslHandler. flush(ChannelHandlerContext ctx, ChannelPromise promise)
private void
SslHandler. safeClose(ChannelHandlerContext ctx, ChannelFuture flushFuture, ChannelPromise promise)
void
SslClientHelloHandler. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)
void
SslHandler. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)
-
Uses of ChannelPromise in io.netty.handler.stream
Fields in io.netty.handler.stream declared as ChannelPromise Modifier and Type Field Description (package private) ChannelPromise
ChunkedWriteHandler.PendingWrite. promise
Methods in io.netty.handler.stream with parameters of type ChannelPromise Modifier and Type Method Description void
ChunkedWriteHandler. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)
Constructors in io.netty.handler.stream with parameters of type ChannelPromise Constructor Description PendingWrite(java.lang.Object msg, ChannelPromise promise)
-
Uses of ChannelPromise in io.netty.handler.timeout
Fields in io.netty.handler.timeout declared as ChannelPromise Modifier and Type Field Description private ChannelPromise
WriteTimeoutHandler.WriteTimeoutTask. promise
Methods in io.netty.handler.timeout with parameters of type ChannelPromise Modifier and Type Method Description private void
WriteTimeoutHandler. scheduleTimeout(ChannelHandlerContext ctx, ChannelPromise promise)
void
IdleStateHandler. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)
void
WriteTimeoutHandler. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)
Constructors in io.netty.handler.timeout with parameters of type ChannelPromise Constructor Description WriteTimeoutTask(ChannelHandlerContext ctx, ChannelPromise promise)
-
Uses of ChannelPromise in io.netty.handler.traffic
Fields in io.netty.handler.traffic declared as ChannelPromise Modifier and Type Field Description (package private) ChannelPromise
ChannelTrafficShapingHandler.ToSend. promise
(package private) ChannelPromise
GlobalChannelTrafficShapingHandler.ToSend. promise
(package private) ChannelPromise
GlobalTrafficShapingHandler.ToSend. promise
Methods in io.netty.handler.traffic with parameters of type ChannelPromise Modifier and Type Method Description (package private) abstract void
AbstractTrafficShapingHandler. submitWrite(ChannelHandlerContext ctx, java.lang.Object msg, long size, long delay, long now, ChannelPromise promise)
protected void
AbstractTrafficShapingHandler. submitWrite(ChannelHandlerContext ctx, java.lang.Object msg, long delay, ChannelPromise promise)
Deprecated.(package private) void
ChannelTrafficShapingHandler. submitWrite(ChannelHandlerContext ctx, java.lang.Object msg, long size, long delay, long now, ChannelPromise promise)
protected void
GlobalChannelTrafficShapingHandler. submitWrite(ChannelHandlerContext ctx, java.lang.Object msg, long size, long writedelay, long now, ChannelPromise promise)
(package private) void
GlobalTrafficShapingHandler. submitWrite(ChannelHandlerContext ctx, java.lang.Object msg, long size, long writedelay, long now, ChannelPromise promise)
void
AbstractTrafficShapingHandler. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)
void
GlobalChannelTrafficShapingHandler. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)
Constructors in io.netty.handler.traffic with parameters of type ChannelPromise Constructor Description ToSend(long delay, java.lang.Object toSend, ChannelPromise promise)
ToSend(long delay, java.lang.Object toSend, long size, ChannelPromise promise)
ToSend(long delay, java.lang.Object toSend, long size, ChannelPromise promise)
-
Uses of ChannelPromise in io.netty.resolver.dns
Methods in io.netty.resolver.dns with parameters of type ChannelPromise Modifier and Type Method Description private void
DnsQueryContext. writeQuery(DnsQuery query, boolean flush, ChannelPromise promise)
-