Uses of Interface
io.netty.channel.ChannelFuture
-
Packages that use ChannelFuture 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.group A channel registry which helps a user maintain the list of openChannel
s and perform bulk operations on them.io.netty.channel.kqueue BSD specific transport.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.pool Implementations and API forChannel
pools.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.codec.compression io.netty.handler.codec.http.websocketx Encoder, decoder, handshakers and their related message types for Web Socket data frames.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.ipfilter Package to filter IP addresses (allow/deny).io.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.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 ChannelFuture in io.netty.bootstrap
Classes in io.netty.bootstrap that implement ChannelFuture Modifier and Type Class Description (package private) static class
AbstractBootstrap.PendingRegistrationPromise
Methods in io.netty.bootstrap that return ChannelFuture Modifier and Type Method Description ChannelFuture
AbstractBootstrap. bind()
Create a newChannel
and bind it.ChannelFuture
AbstractBootstrap. bind(int inetPort)
Create a newChannel
and bind it.ChannelFuture
AbstractBootstrap. bind(java.lang.String inetHost, int inetPort)
Create a newChannel
and bind it.ChannelFuture
AbstractBootstrap. bind(java.net.InetAddress inetHost, int inetPort)
Create a newChannel
and bind it.ChannelFuture
AbstractBootstrap. bind(java.net.SocketAddress localAddress)
Create a newChannel
and bind it.ChannelFuture
Bootstrap. connect()
Connect aChannel
to the remote peer.ChannelFuture
Bootstrap. connect(java.lang.String inetHost, int inetPort)
Connect aChannel
to the remote peer.ChannelFuture
Bootstrap. connect(java.net.InetAddress inetHost, int inetPort)
Connect aChannel
to the remote peer.ChannelFuture
Bootstrap. connect(java.net.SocketAddress remoteAddress)
Connect aChannel
to the remote peer.ChannelFuture
Bootstrap. connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress)
Connect aChannel
to the remote peer.private ChannelFuture
AbstractBootstrap. doBind(java.net.SocketAddress localAddress)
private ChannelFuture
Bootstrap. doResolveAndConnect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress)
private ChannelFuture
Bootstrap. doResolveAndConnect0(Channel channel, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
(package private) ChannelFuture
AbstractBootstrap. initAndRegister()
ChannelFuture
AbstractBootstrap. register()
Methods in io.netty.bootstrap with parameters of type ChannelFuture Modifier and Type Method Description private static void
AbstractBootstrap. doBind0(ChannelFuture regFuture, Channel channel, java.net.SocketAddress localAddress, ChannelPromise promise)
-
Uses of ChannelFuture in io.netty.channel
Subinterfaces of ChannelFuture in io.netty.channel Modifier and Type Interface Description interface
ChannelProgressiveFuture
An specialChannelFuture
which is used to indicate theFileRegion
transfer progressinterface
ChannelProgressivePromise
SpecialChannelPromise
which will be notified once the associated bytes is transferring.interface
ChannelPromise
SpecialChannelFuture
which is writable.Classes in io.netty.channel that implement ChannelFuture Modifier and Type Class Description (package private) static class
AbstractChannel.CloseFuture
(package private) class
CompleteChannelFuture
A skeletalChannelFuture
implementation which represents aChannelFuture
which has been completed already.class
DefaultChannelProgressivePromise
The defaultChannelProgressivePromise
implementation.class
DefaultChannelPromise
The defaultChannelPromise
implementation.class
DelegatingChannelPromiseNotifier
(package private) class
FailedChannelFuture
TheCompleteChannelFuture
which is failed already.(package private) class
SucceededChannelFuture
TheCompleteChannelFuture
which is succeeded already.class
VoidChannelPromise
Fields in io.netty.channel declared as ChannelFuture Modifier and Type Field Description private ChannelFuture
AbstractChannelHandlerContext. succeededFuture
private ChannelFuture
DefaultChannelPipeline. succeededFuture
Methods in io.netty.channel that return ChannelFuture Modifier and Type Method Description ChannelFuture
ChannelFuture. addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
ChannelFuture
CompleteChannelFuture. addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
ChannelFuture
ChannelFuture. addListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners)
ChannelFuture
CompleteChannelFuture. addListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners)
ChannelFuture
ChannelFuture. await()
ChannelFuture
CompleteChannelFuture. await()
ChannelFuture
ChannelFuture. awaitUninterruptibly()
ChannelFuture
CompleteChannelFuture. awaitUninterruptibly()
ChannelFuture
AbstractChannel. bind(java.net.SocketAddress localAddress)
ChannelFuture
AbstractChannel. bind(java.net.SocketAddress localAddress, ChannelPromise promise)
ChannelFuture
AbstractChannelHandlerContext. bind(java.net.SocketAddress localAddress)
ChannelFuture
AbstractChannelHandlerContext. bind(java.net.SocketAddress localAddress, ChannelPromise promise)
ChannelFuture
ChannelOutboundInvoker. bind(java.net.SocketAddress localAddress)
Request to bind to the givenSocketAddress
and notify theChannelFuture
once the operation completes, either because the operation was successful or because of an error.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.ChannelFuture
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext. bind(java.net.SocketAddress localAddress)
ChannelFuture
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext. bind(java.net.SocketAddress localAddress, ChannelPromise promise)
ChannelFuture
DefaultChannelPipeline. bind(java.net.SocketAddress localAddress)
ChannelFuture
DefaultChannelPipeline. bind(java.net.SocketAddress localAddress, ChannelPromise promise)
ChannelFuture
AbstractChannel. close()
ChannelFuture
AbstractChannel. close(ChannelPromise promise)
ChannelFuture
AbstractChannelHandlerContext. close()
ChannelFuture
AbstractChannelHandlerContext. close(ChannelPromise promise)
ChannelFuture
ChannelOutboundInvoker. close()
Request to close theChannel
and notify theChannelFuture
once the operation completes, either because the operation was successful or because of an error.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.ChannelFuture
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext. close()
ChannelFuture
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext. close(ChannelPromise promise)
ChannelFuture
DefaultChannelPipeline. close()
ChannelFuture
DefaultChannelPipeline. close(ChannelPromise promise)
ChannelFuture
AbstractChannel. closeFuture()
ChannelFuture
Channel. closeFuture()
Returns theChannelFuture
which will be notified when this channel is closed.ChannelFuture
AbstractChannel. connect(java.net.SocketAddress remoteAddress)
ChannelFuture
AbstractChannel. connect(java.net.SocketAddress remoteAddress, ChannelPromise promise)
ChannelFuture
AbstractChannel. connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress)
ChannelFuture
AbstractChannel. connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
ChannelFuture
AbstractChannelHandlerContext. connect(java.net.SocketAddress remoteAddress)
ChannelFuture
AbstractChannelHandlerContext. connect(java.net.SocketAddress remoteAddress, ChannelPromise promise)
ChannelFuture
AbstractChannelHandlerContext. connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress)
ChannelFuture
AbstractChannelHandlerContext. connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
ChannelFuture
ChannelOutboundInvoker. connect(java.net.SocketAddress remoteAddress)
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, 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)
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.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.ChannelFuture
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext. connect(java.net.SocketAddress remoteAddress)
ChannelFuture
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext. connect(java.net.SocketAddress remoteAddress, ChannelPromise promise)
ChannelFuture
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext. connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress)
ChannelFuture
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext. connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
ChannelFuture
DefaultChannelPipeline. connect(java.net.SocketAddress remoteAddress)
ChannelFuture
DefaultChannelPipeline. connect(java.net.SocketAddress remoteAddress, ChannelPromise promise)
ChannelFuture
DefaultChannelPipeline. connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress)
ChannelFuture
DefaultChannelPipeline. connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
ChannelFuture
AbstractChannel. deregister()
ChannelFuture
AbstractChannel. deregister(ChannelPromise promise)
ChannelFuture
AbstractChannelHandlerContext. deregister()
ChannelFuture
AbstractChannelHandlerContext. deregister(ChannelPromise promise)
ChannelFuture
ChannelOutboundInvoker. deregister()
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
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()
ChannelFuture
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext. deregister(ChannelPromise promise)
ChannelFuture
DefaultChannelPipeline. deregister()
ChannelFuture
DefaultChannelPipeline. deregister(ChannelPromise promise)
ChannelFuture
AbstractChannel. disconnect()
ChannelFuture
AbstractChannel. disconnect(ChannelPromise promise)
ChannelFuture
AbstractChannelHandlerContext. disconnect()
ChannelFuture
AbstractChannelHandlerContext. disconnect(ChannelPromise promise)
ChannelFuture
ChannelOutboundInvoker. disconnect()
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
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()
ChannelFuture
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext. disconnect(ChannelPromise promise)
ChannelFuture
DefaultChannelPipeline. disconnect()
ChannelFuture
DefaultChannelPipeline. disconnect(ChannelPromise promise)
ChannelFuture
AbstractChannel. newFailedFuture(java.lang.Throwable cause)
ChannelFuture
AbstractChannelHandlerContext. newFailedFuture(java.lang.Throwable cause)
ChannelFuture
ChannelOutboundInvoker. newFailedFuture(java.lang.Throwable cause)
Create a newChannelFuture
which is marked as failed already.ChannelFuture
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext. newFailedFuture(java.lang.Throwable cause)
ChannelFuture
DefaultChannelPipeline. newFailedFuture(java.lang.Throwable cause)
ChannelFuture
AbstractChannel. newSucceededFuture()
ChannelFuture
AbstractChannelHandlerContext. newSucceededFuture()
ChannelFuture
ChannelOutboundInvoker. newSucceededFuture()
Create a newChannelFuture
which is marked as succeeded already.ChannelFuture
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext. newSucceededFuture()
ChannelFuture
DefaultChannelPipeline. newSucceededFuture()
ChannelFuture
EventLoopGroup. register(Channel channel)
ChannelFuture
EventLoopGroup. register(ChannelPromise promise)
ChannelFuture
EventLoopGroup. register(Channel channel, ChannelPromise promise)
Deprecated.UseEventLoopGroup.register(ChannelPromise)
instead.ChannelFuture
MultithreadEventLoopGroup. register(Channel channel)
ChannelFuture
MultithreadEventLoopGroup. register(ChannelPromise promise)
ChannelFuture
MultithreadEventLoopGroup. register(Channel channel, ChannelPromise promise)
Deprecated.ChannelFuture
SingleThreadEventLoop. register(Channel channel)
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(Channel channel)
Deprecated.ChannelFuture
ThreadPerChannelEventLoopGroup. register(ChannelPromise promise)
Deprecated.ChannelFuture
ThreadPerChannelEventLoopGroup. register(Channel channel, ChannelPromise promise)
Deprecated.ChannelFuture
PendingWriteQueue. removeAndWrite()
Removes a pending write operation and performs it viaChannelOutboundInvoker.write(Object, ChannelPromise)
.ChannelFuture
PendingWriteQueue. removeAndWriteAll()
Remove all pending write operation and performs them viaChannelOutboundInvoker.write(Object, ChannelPromise)
.ChannelFuture
ChannelFuture. removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
ChannelFuture
CompleteChannelFuture. removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)
ChannelFuture
ChannelFuture. removeListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners)
ChannelFuture
CompleteChannelFuture. removeListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners)
ChannelFuture
ChannelFuture. sync()
ChannelFuture
CompleteChannelFuture. sync()
ChannelFuture
FailedChannelFuture. sync()
ChannelFuture
ChannelFuture. syncUninterruptibly()
ChannelFuture
CompleteChannelFuture. syncUninterruptibly()
ChannelFuture
FailedChannelFuture. syncUninterruptibly()
ChannelFuture
AbstractChannel. write(java.lang.Object msg)
ChannelFuture
AbstractChannel. write(java.lang.Object msg, ChannelPromise promise)
ChannelFuture
AbstractChannelHandlerContext. write(java.lang.Object msg)
ChannelFuture
AbstractChannelHandlerContext. write(java.lang.Object msg, ChannelPromise promise)
ChannelFuture
ChannelOutboundInvoker. write(java.lang.Object msg)
Request to write a message via thisChannelHandlerContext
through 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)
ChannelFuture
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext. write(java.lang.Object msg, ChannelPromise promise)
ChannelFuture
DefaultChannelPipeline. write(java.lang.Object msg)
ChannelFuture
DefaultChannelPipeline. write(java.lang.Object msg, ChannelPromise promise)
ChannelFuture
AbstractChannel. writeAndFlush(java.lang.Object msg)
ChannelFuture
AbstractChannel. writeAndFlush(java.lang.Object msg, ChannelPromise promise)
ChannelFuture
AbstractChannelHandlerContext. writeAndFlush(java.lang.Object msg)
ChannelFuture
AbstractChannelHandlerContext. writeAndFlush(java.lang.Object msg, ChannelPromise promise)
ChannelFuture
ChannelOutboundInvoker. writeAndFlush(java.lang.Object msg)
Shortcut for callChannelOutboundInvoker.write(Object)
andChannelOutboundInvoker.flush()
.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)
ChannelFuture
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext. writeAndFlush(java.lang.Object msg, ChannelPromise promise)
ChannelFuture
DefaultChannelPipeline. writeAndFlush(java.lang.Object msg)
ChannelFuture
DefaultChannelPipeline. writeAndFlush(java.lang.Object msg, ChannelPromise promise)
Methods in io.netty.channel with parameters of type ChannelFuture Modifier and Type Method Description void
DelegatingChannelPromiseNotifier. operationComplete(ChannelFuture future)
private void
AbstractCoalescingBufferQueue. releaseAndCompleteAll(ChannelFuture future)
-
Uses of ChannelFuture in io.netty.channel.embedded
Methods in io.netty.channel.embedded that return ChannelFuture Modifier and Type Method Description private ChannelFuture
EmbeddedChannel. checkException(ChannelPromise promise)
Checks for the presence of anException
.ChannelFuture
EmbeddedChannel. close()
ChannelFuture
EmbeddedChannel. close(ChannelPromise promise)
ChannelFuture
EmbeddedChannel. disconnect()
ChannelFuture
EmbeddedChannel. disconnect(ChannelPromise promise)
private ChannelFuture
EmbeddedChannel. flushInbound(boolean recordException, ChannelPromise promise)
ChannelFuture
EmbeddedEventLoop. register(Channel channel)
ChannelFuture
EmbeddedEventLoop. register(ChannelPromise promise)
ChannelFuture
EmbeddedEventLoop. register(Channel channel, ChannelPromise promise)
Deprecated.ChannelFuture
EmbeddedChannel. writeOneInbound(java.lang.Object msg)
Writes one message to the inbound of thisChannel
and does not flush it.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)
Writes one message to the outbound 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.Methods in io.netty.channel.embedded with parameters of type ChannelFuture Modifier and Type Method Description private void
EmbeddedChannel. recordException(ChannelFuture future)
-
Uses of ChannelFuture in io.netty.channel.epoll
Methods in io.netty.channel.epoll that return ChannelFuture Modifier and Type Method Description ChannelFuture
EpollDatagramChannel. block(java.net.InetAddress multicastAddress, java.net.InetAddress sourceToBlock)
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)
ChannelFuture
EpollDatagramChannel. block(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress sourceToBlock, ChannelPromise promise)
ChannelFuture
EpollDatagramChannel. joinGroup(java.net.InetAddress multicastAddress)
ChannelFuture
EpollDatagramChannel. joinGroup(java.net.InetAddress multicastAddress, ChannelPromise promise)
ChannelFuture
EpollDatagramChannel. joinGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source)
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)
ChannelFuture
EpollDatagramChannel. joinGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface, ChannelPromise promise)
ChannelFuture
EpollDatagramChannel. leaveGroup(java.net.InetAddress multicastAddress)
ChannelFuture
EpollDatagramChannel. leaveGroup(java.net.InetAddress multicastAddress, ChannelPromise promise)
ChannelFuture
EpollDatagramChannel. leaveGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source)
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)
ChannelFuture
EpollDatagramChannel. leaveGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface, ChannelPromise promise)
ChannelFuture
AbstractEpollStreamChannel. shutdown()
ChannelFuture
AbstractEpollStreamChannel. shutdown(ChannelPromise promise)
ChannelFuture
AbstractEpollStreamChannel. shutdownInput()
ChannelFuture
AbstractEpollStreamChannel. shutdownInput(ChannelPromise promise)
ChannelFuture
AbstractEpollStreamChannel. shutdownOutput()
ChannelFuture
AbstractEpollStreamChannel. shutdownOutput(ChannelPromise promise)
ChannelFuture
AbstractEpollStreamChannel. spliceTo(AbstractEpollStreamChannel ch, int len)
Splice from thisAbstractEpollStreamChannel
to anotherAbstractEpollStreamChannel
.ChannelFuture
AbstractEpollStreamChannel. spliceTo(AbstractEpollStreamChannel ch, int len, ChannelPromise promise)
Splice from thisAbstractEpollStreamChannel
to anotherAbstractEpollStreamChannel
.ChannelFuture
AbstractEpollStreamChannel. spliceTo(FileDescriptor ch, int offset, int len)
Splice from thisAbstractEpollStreamChannel
to anotherFileDescriptor
.ChannelFuture
AbstractEpollStreamChannel. spliceTo(FileDescriptor ch, int offset, int len, ChannelPromise promise)
Splice from thisAbstractEpollStreamChannel
to anotherFileDescriptor
.Methods in io.netty.channel.epoll with parameters of type ChannelFuture Modifier and Type Method Description void
AbstractEpollStreamChannel.SpliceInChannelTask. operationComplete(ChannelFuture future)
private static void
AbstractEpollStreamChannel. shutdownDone(ChannelFuture shutdownOutputFuture, ChannelFuture shutdownInputFuture, ChannelPromise promise)
private void
AbstractEpollStreamChannel. shutdownOutputDone(ChannelFuture shutdownOutputFuture, ChannelPromise promise)
-
Uses of ChannelFuture in io.netty.channel.group
Fields in io.netty.channel.group with type parameters of type ChannelFuture Modifier and Type Field Description private static java.util.Iterator<ChannelFuture>
VoidChannelGroupFuture. EMPTY
private java.util.Map<Channel,ChannelFuture>
DefaultChannelGroupFuture. futures
Methods in io.netty.channel.group that return ChannelFuture Modifier and Type Method Description ChannelFuture
ChannelGroupFuture. find(Channel channel)
Returns theChannelFuture
of the individual I/O operation which is associated with the specifiedChannel
.ChannelFuture
DefaultChannelGroupFuture. find(Channel channel)
ChannelFuture
VoidChannelGroupFuture. find(Channel channel)
Methods in io.netty.channel.group that return types with arguments of type ChannelFuture Modifier and Type Method Description java.util.Iterator<ChannelFuture>
ChannelGroupFuture. iterator()
Returns theIterator
that enumerates allChannelFuture
s which are associated with this future.java.util.Iterator<ChannelFuture>
DefaultChannelGroupFuture. iterator()
java.util.Iterator<ChannelFuture>
VoidChannelGroupFuture. iterator()
Constructor parameters in io.netty.channel.group with type arguments of type ChannelFuture Constructor Description DefaultChannelGroupFuture(ChannelGroup group, java.util.Collection<ChannelFuture> futures, EventExecutor executor)
Creates a new instance.DefaultChannelGroupFuture(ChannelGroup group, java.util.Map<Channel,ChannelFuture> futures, EventExecutor executor)
-
Uses of ChannelFuture in io.netty.channel.kqueue
Methods in io.netty.channel.kqueue that return ChannelFuture Modifier and Type Method Description ChannelFuture
KQueueDatagramChannel. block(java.net.InetAddress multicastAddress, java.net.InetAddress sourceToBlock)
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)
ChannelFuture
KQueueDatagramChannel. block(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress sourceToBlock, ChannelPromise promise)
ChannelFuture
KQueueDatagramChannel. joinGroup(java.net.InetAddress multicastAddress)
ChannelFuture
KQueueDatagramChannel. joinGroup(java.net.InetAddress multicastAddress, ChannelPromise promise)
ChannelFuture
KQueueDatagramChannel. joinGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source)
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)
ChannelFuture
KQueueDatagramChannel. joinGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface, ChannelPromise promise)
ChannelFuture
KQueueDatagramChannel. leaveGroup(java.net.InetAddress multicastAddress)
ChannelFuture
KQueueDatagramChannel. leaveGroup(java.net.InetAddress multicastAddress, ChannelPromise promise)
ChannelFuture
KQueueDatagramChannel. leaveGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source)
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)
ChannelFuture
KQueueDatagramChannel. leaveGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface, ChannelPromise promise)
ChannelFuture
AbstractKQueueStreamChannel. shutdown()
ChannelFuture
AbstractKQueueStreamChannel. shutdown(ChannelPromise promise)
ChannelFuture
AbstractKQueueStreamChannel. shutdownInput()
ChannelFuture
AbstractKQueueStreamChannel. shutdownInput(ChannelPromise promise)
ChannelFuture
AbstractKQueueStreamChannel. shutdownOutput()
ChannelFuture
AbstractKQueueStreamChannel. shutdownOutput(ChannelPromise promise)
Methods in io.netty.channel.kqueue with parameters of type ChannelFuture Modifier and Type Method Description private static void
AbstractKQueueStreamChannel. shutdownDone(ChannelFuture shutdownOutputFuture, ChannelFuture shutdownInputFuture, ChannelPromise promise)
private void
AbstractKQueueStreamChannel. shutdownOutputDone(ChannelFuture shutdownOutputFuture, ChannelPromise promise)
-
Uses of ChannelFuture in io.netty.channel.nio
Methods in io.netty.channel.nio that return ChannelFuture Modifier and Type Method Description protected abstract ChannelFuture
AbstractNioByteChannel. shutdownInput()
Shutdown the input side of the channel. -
Uses of ChannelFuture in io.netty.channel.oio
Methods in io.netty.channel.oio that return ChannelFuture Modifier and Type Method Description protected abstract ChannelFuture
AbstractOioByteChannel. shutdownInput()
Deprecated.Shutdown the input side of this channel. -
Uses of ChannelFuture in io.netty.channel.pool
Methods in io.netty.channel.pool that return ChannelFuture Modifier and Type Method Description protected ChannelFuture
SimpleChannelPool. connectChannel(Bootstrap bs)
Bootstrap a newChannel
.Methods in io.netty.channel.pool with parameters of type ChannelFuture Modifier and Type Method Description private void
SimpleChannelPool. notifyConnect(ChannelFuture future, Promise<Channel> promise)
-
Uses of ChannelFuture in io.netty.channel.socket
Methods in io.netty.channel.socket that return ChannelFuture Modifier and Type Method Description ChannelFuture
DatagramChannel. block(java.net.InetAddress multicastAddress, java.net.InetAddress sourceToBlock)
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.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)
Block the given sourceToBlock address for the given multicastAddress on the given networkInterface 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)
Joins a multicast group 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)
Joins the specified multicast group at the specified interface 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)
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)
Leaves a multicast group 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)
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.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)
Leaves a multicast group on a specified local interface 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()
Will shutdown the input and output sides of this channel.ChannelFuture
DuplexChannel. shutdown(ChannelPromise promise)
Will shutdown the input and output sides of this channel.ChannelFuture
DuplexChannel. shutdownInput()
ChannelFuture
DuplexChannel. shutdownInput(ChannelPromise promise)
Will shutdown the input and notifyChannelPromise
.ChannelFuture
DuplexChannel. shutdownOutput()
ChannelFuture
DuplexChannel. shutdownOutput(ChannelPromise promise)
Will shutdown the output and notifyChannelPromise
. -
Uses of ChannelFuture in io.netty.channel.socket.nio
Methods in io.netty.channel.socket.nio that return ChannelFuture Modifier and Type Method Description ChannelFuture
NioDatagramChannel. block(java.net.InetAddress multicastAddress, java.net.InetAddress sourceToBlock)
Block the given sourceToBlock address for the given multicastAddressChannelFuture
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)
Block the given sourceToBlock address for the given multicastAddress on the given networkInterfaceChannelFuture
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)
ChannelFuture
NioDatagramChannel. joinGroup(java.net.InetAddress multicastAddress, ChannelPromise promise)
ChannelFuture
NioDatagramChannel. joinGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source)
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)
ChannelFuture
NioDatagramChannel. joinGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface, ChannelPromise promise)
ChannelFuture
NioDatagramChannel. leaveGroup(java.net.InetAddress multicastAddress)
ChannelFuture
NioDatagramChannel. leaveGroup(java.net.InetAddress multicastAddress, ChannelPromise promise)
ChannelFuture
NioDatagramChannel. leaveGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source)
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)
ChannelFuture
NioDatagramChannel. leaveGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface, ChannelPromise promise)
ChannelFuture
NioSocketChannel. shutdown()
ChannelFuture
NioSocketChannel. shutdown(ChannelPromise promise)
ChannelFuture
NioSocketChannel. shutdownInput()
ChannelFuture
NioSocketChannel. shutdownInput(ChannelPromise promise)
ChannelFuture
NioSocketChannel. shutdownOutput()
ChannelFuture
NioSocketChannel. shutdownOutput(ChannelPromise promise)
Methods in io.netty.channel.socket.nio with parameters of type ChannelFuture Modifier and Type Method Description private static void
NioSocketChannel. shutdownDone(ChannelFuture shutdownOutputFuture, ChannelFuture shutdownInputFuture, ChannelPromise promise)
private void
NioSocketChannel. shutdownOutputDone(ChannelFuture shutdownOutputFuture, ChannelPromise promise)
-
Uses of ChannelFuture in io.netty.channel.socket.oio
Methods in io.netty.channel.socket.oio that return ChannelFuture Modifier and Type Method Description ChannelFuture
OioDatagramChannel. block(java.net.InetAddress multicastAddress, java.net.InetAddress sourceToBlock)
Deprecated.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)
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)
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)
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)
Deprecated.ChannelFuture
OioDatagramChannel. joinGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface, ChannelPromise promise)
Deprecated.ChannelFuture
OioDatagramChannel. leaveGroup(java.net.InetAddress multicastAddress)
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)
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)
Deprecated.ChannelFuture
OioDatagramChannel. leaveGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface, ChannelPromise promise)
Deprecated.ChannelFuture
OioSocketChannel. shutdown()
Deprecated.ChannelFuture
OioSocketChannel. shutdown(ChannelPromise promise)
Deprecated.ChannelFuture
OioSocketChannel. shutdownInput()
Deprecated.ChannelFuture
OioSocketChannel. shutdownInput(ChannelPromise promise)
Deprecated.ChannelFuture
OioSocketChannel. shutdownOutput()
Deprecated.ChannelFuture
OioSocketChannel. shutdownOutput(ChannelPromise promise)
Deprecated.Methods in io.netty.channel.socket.oio with parameters of type ChannelFuture Modifier and Type Method Description private static void
OioSocketChannel. shutdownDone(ChannelFuture shutdownOutputFuture, ChannelFuture shutdownInputFuture, ChannelPromise promise)
Deprecated.private void
OioSocketChannel. shutdownOutputDone(ChannelFuture shutdownOutputFuture, ChannelPromise promise)
Deprecated. -
Uses of ChannelFuture in io.netty.handler.codec.compression
Methods in io.netty.handler.codec.compression that return ChannelFuture Modifier and Type Method Description ChannelFuture
Bzip2Encoder. close()
Close thisBzip2Encoder
and so finish the encoding.ChannelFuture
Bzip2Encoder. close(ChannelPromise promise)
Close thisBzip2Encoder
and so finish the encoding.ChannelFuture
JdkZlibEncoder. close()
ChannelFuture
JdkZlibEncoder. close(ChannelPromise promise)
ChannelFuture
JZlibEncoder. close()
ChannelFuture
JZlibEncoder. close(ChannelPromise promise)
abstract ChannelFuture
ZlibEncoder. close()
Close thisZlibEncoder
and so finish the encoding.abstract ChannelFuture
ZlibEncoder. close(ChannelPromise promise)
Close thisZlibEncoder
and so finish the encoding.private ChannelFuture
Bzip2Encoder. finishEncode(ChannelHandlerContext ctx, ChannelPromise promise)
private ChannelFuture
JdkZlibEncoder. finishEncode(ChannelHandlerContext ctx, ChannelPromise promise)
private ChannelFuture
JZlibEncoder. finishEncode(ChannelHandlerContext ctx, ChannelPromise promise)
Methods in io.netty.handler.codec.compression with parameters of type ChannelFuture Modifier and Type Method Description (package private) static void
EncoderUtil. closeAfterFinishEncode(ChannelHandlerContext ctx, ChannelFuture finishFuture, ChannelPromise promise)
-
Uses of ChannelFuture in io.netty.handler.codec.http.websocketx
Methods in io.netty.handler.codec.http.websocketx that return ChannelFuture Modifier and Type Method Description ChannelFuture
WebSocketClientHandshaker. close(ChannelHandlerContext ctx, CloseWebSocketFrame frame)
Performs the closing handshakeChannelFuture
WebSocketClientHandshaker. close(ChannelHandlerContext ctx, CloseWebSocketFrame frame, ChannelPromise promise)
Performs the closing handshakeChannelFuture
WebSocketClientHandshaker. close(Channel channel, CloseWebSocketFrame frame)
Performs the closing handshake.ChannelFuture
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)
.ChannelFuture
WebSocketServerHandshaker. close(ChannelHandlerContext ctx, CloseWebSocketFrame frame)
Performs the closing handshake.ChannelFuture
WebSocketServerHandshaker. close(ChannelHandlerContext ctx, CloseWebSocketFrame frame, ChannelPromise promise)
Performs the closing handshake.ChannelFuture
WebSocketServerHandshaker. close(Channel channel, CloseWebSocketFrame frame)
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) ChannelFuture
WebSocketClientProtocolHandshakeHandler. getHandshakeFuture()
This method is visible for testing.ChannelFuture
WebSocketClientHandshaker. handshake(Channel channel)
Begins the opening handshakeChannelFuture
WebSocketClientHandshaker. handshake(Channel channel, ChannelPromise promise)
Begins the opening handshakeChannelFuture
WebSocketServerHandshaker. handshake(Channel channel, FullHttpRequest req)
Performs the opening handshake.ChannelFuture
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)
Performs the opening handshake.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)
Process the opening handshake initiated byWebSocketClientHandshaker.handshake(io.netty.channel.Channel)
}.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)
Return that we need cannot support the web socket versionstatic ChannelFuture
WebSocketServerHandshakerFactory. sendUnsupportedVersionResponse(Channel channel, ChannelPromise promise)
Return that we need cannot support the web socket version -
Uses of ChannelFuture in io.netty.handler.codec.http2
Classes in io.netty.handler.codec.http2 that implement ChannelFuture 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.Methods in io.netty.handler.codec.http2 that return ChannelFuture Modifier and Type Method Description ChannelFuture
AbstractHttp2StreamChannel. bind(java.net.SocketAddress localAddress)
ChannelFuture
AbstractHttp2StreamChannel. bind(java.net.SocketAddress localAddress, ChannelPromise promise)
ChannelFuture
AbstractHttp2StreamChannel. close()
ChannelFuture
AbstractHttp2StreamChannel. close(ChannelPromise promise)
ChannelFuture
AbstractHttp2StreamChannel. closeFuture()
ChannelFuture
AbstractHttp2StreamChannel. connect(java.net.SocketAddress remoteAddress)
ChannelFuture
AbstractHttp2StreamChannel. connect(java.net.SocketAddress remoteAddress, ChannelPromise promise)
ChannelFuture
AbstractHttp2StreamChannel. connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress)
ChannelFuture
AbstractHttp2StreamChannel. connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
ChannelFuture
AbstractHttp2StreamChannel. deregister()
ChannelFuture
AbstractHttp2StreamChannel. deregister(ChannelPromise promise)
ChannelFuture
AbstractHttp2StreamChannel. disconnect()
ChannelFuture
AbstractHttp2StreamChannel. disconnect(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
.ChannelFuture
AbstractHttp2StreamChannel. newFailedFuture(java.lang.Throwable cause)
ChannelFuture
AbstractHttp2StreamChannel. newSucceededFuture()
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 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
.ChannelFuture
AbstractHttp2StreamChannel. write(java.lang.Object msg)
ChannelFuture
AbstractHttp2StreamChannel. write(java.lang.Object msg, ChannelPromise promise)
protected ChannelFuture
AbstractHttp2StreamChannel. write0(ChannelHandlerContext ctx, java.lang.Object msg)
protected ChannelFuture
Http2MultiplexCodec.Http2MultiplexCodecStreamChannel. write0(ChannelHandlerContext ctx, java.lang.Object msg)
ChannelFuture
AbstractHttp2StreamChannel. writeAndFlush(java.lang.Object msg)
ChannelFuture
AbstractHttp2StreamChannel. writeAndFlush(java.lang.Object msg, ChannelPromise promise)
private ChannelFuture
DefaultHttp2FrameWriter. writeContinuationFrames(ChannelHandlerContext ctx, int streamId, ByteBuf headerBlock, Http2CodecUtil.SimpleChannelPromiseAggregator promiseAggregator)
Writes as many continuation frames as needed untilpadding
andheaderBlock
are consumed.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)
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
DefaultHttp2FrameWriter. writeHeadersInternal(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream, boolean hasPriority, int streamDependency, short weight, boolean exclusive, 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)
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
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)
Methods in io.netty.handler.codec.http2 with parameters of type ChannelFuture Modifier and Type Method Description private void
Http2ConnectionHandler. checkCloseConnection(ChannelFuture future)
Closes the connection if the graceful shutdown process has completed.private void
Http2ConnectionHandler. closeConnectionOnError(ChannelHandlerContext ctx, ChannelFuture future)
void
Http2ConnectionHandler. closeStream(Http2Stream stream, ChannelFuture future)
void
Http2LifecycleManager. closeStream(Http2Stream stream, ChannelFuture future)
Closes and deactivates the givenstream
.void
Http2ConnectionHandler. closeStreamLocal(Http2Stream stream, ChannelFuture future)
Closes the local side of the given stream.void
Http2LifecycleManager. closeStreamLocal(Http2Stream stream, ChannelFuture future)
Closes the local side of thestream
.void
Http2ConnectionHandler. closeStreamRemote(Http2Stream stream, ChannelFuture future)
Closes the remote side of the given stream.void
Http2LifecycleManager. closeStreamRemote(Http2Stream stream, ChannelFuture future)
Closes the remote side of thestream
.private void
Http2ConnectionHandler. doCloseStream(Http2Stream stream, ChannelFuture future)
private void
Http2ConnectionHandler. doGracefulShutdown(ChannelHandlerContext ctx, ChannelFuture future, ChannelPromise promise)
private void
AbstractHttp2StreamChannel.Http2ChannelUnsafe. firstWriteComplete(ChannelFuture future, ChannelPromise promise)
private void
Http2FrameCodec. handleHeaderFuture(ChannelFuture channelFuture, int streamId)
private void
DefaultHttp2ConnectionEncoder. notifyLifecycleManagerOnError(ChannelFuture future, ChannelHandlerContext ctx)
void
DefaultHttp2ConnectionEncoder.FlowControlledBase. operationComplete(ChannelFuture future)
void
Http2ConnectionHandler.ClosingChannelFutureListener. operationComplete(ChannelFuture sentGoAwayFuture)
private static void
Http2ConnectionHandler. processGoAwayWriteResult(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData, ChannelFuture future)
private void
Http2ConnectionHandler. processRstStreamWriteResult(ChannelHandlerContext ctx, Http2Stream stream, ChannelFuture future)
(package private) static void
Http2MultiplexHandler. registerDone(ChannelFuture future)
private static void
AbstractHttp2StreamChannel. windowUpdateFrameWriteComplete(ChannelFuture future, Channel streamChannel)
private void
AbstractHttp2StreamChannel.Http2ChannelUnsafe. writeComplete(ChannelFuture future, ChannelPromise promise)
-
Uses of ChannelFuture in io.netty.handler.codec.spdy
Methods in io.netty.handler.codec.spdy that return ChannelFuture Modifier and Type Method Description private ChannelFuture
SpdySessionHandler. sendGoAwayFrame(ChannelHandlerContext ctx, SpdySessionStatus status)
Methods in io.netty.handler.codec.spdy with parameters of type ChannelFuture Modifier and Type Method Description private void
SpdySessionHandler. halfCloseStream(int streamId, boolean remote, ChannelFuture future)
void
SpdySessionHandler.ClosingChannelFutureListener. operationComplete(ChannelFuture sentGoAwayFuture)
private void
SpdySessionHandler. removeStream(int streamId, ChannelFuture future)
-
Uses of ChannelFuture in io.netty.handler.ipfilter
Methods in io.netty.handler.ipfilter that return ChannelFuture Modifier and Type Method Description protected ChannelFuture
AbstractRemoteAddressFilter. channelRejected(ChannelHandlerContext ctx, T remoteAddress)
This method is called ifremoteAddress
gets rejected byAbstractRemoteAddressFilter.accept(ChannelHandlerContext, SocketAddress)
. -
Uses of ChannelFuture in io.netty.handler.ssl
Methods in io.netty.handler.ssl that return ChannelFuture Modifier and Type Method Description ChannelFuture
SslHandler. close()
Deprecated.ChannelFuture
SslHandler. close(ChannelPromise promise)
Deprecated.ChannelFuture
SslHandler. closeOutbound()
Sends an SSLclose_notify
message to the specified channel and destroys the underlyingSSLEngine
.ChannelFuture
SslHandler. closeOutbound(ChannelPromise promise)
Sends an SSLclose_notify
message to the specified channel and destroys the underlyingSSLEngine
.Methods in io.netty.handler.ssl with parameters of type ChannelFuture Modifier and Type Method Description private static void
SslHandler. addCloseListener(ChannelFuture future, ChannelPromise promise)
private void
SslHandler. safeClose(ChannelHandlerContext ctx, ChannelFuture flushFuture, ChannelPromise promise)
-
Uses of ChannelFuture in io.netty.handler.stream
Methods in io.netty.handler.stream with parameters of type ChannelFuture Modifier and Type Method Description private static void
ChunkedWriteHandler. handleEndOfInputFuture(ChannelFuture future, ChunkedInput<?> input, ChunkedWriteHandler.PendingWrite currentWrite)
private void
ChunkedWriteHandler. handleFuture(ChannelFuture future, ChunkedInput<?> input, ChunkedWriteHandler.PendingWrite currentWrite, boolean resume)
-
Uses of ChannelFuture in io.netty.handler.timeout
Methods in io.netty.handler.timeout with parameters of type ChannelFuture Modifier and Type Method Description void
WriteTimeoutHandler.WriteTimeoutTask. operationComplete(ChannelFuture future)
-
Uses of ChannelFuture in io.netty.resolver.dns
Methods in io.netty.resolver.dns that return ChannelFuture Modifier and Type Method Description private ChannelFuture
DnsQueryContext. sendQuery(DnsQuery query, boolean flush)
(package private) ChannelFuture
DnsQueryContext. writeQuery(boolean flush)
Write the query and return theChannelFuture
that is completed once the write completes.Methods in io.netty.resolver.dns with parameters of type ChannelFuture Modifier and Type Method Description private void
DnsQueryContext. onQueryWriteCompletion(long queryTimeoutMillis, ChannelFuture writeFuture)
void
BiDnsQueryLifecycleObserver. queryWritten(java.net.InetSocketAddress dnsServerAddress, ChannelFuture future)
void
DnsQueryLifecycleObserver. queryWritten(java.net.InetSocketAddress dnsServerAddress, ChannelFuture future)
The query has been written.void
LoggingDnsQueryLifecycleObserver. queryWritten(java.net.InetSocketAddress dnsServerAddress, ChannelFuture future)
void
NoopDnsQueryLifecycleObserver. queryWritten(java.net.InetSocketAddress dnsServerAddress, ChannelFuture future)
-