Uses of Interface
io.netty.channel.ChannelFuture
Packages that use ChannelFuture
Package
Description
The helper classes with fluent API which enable an easy implementation of
typical client side and server side channel initialization.
The core channel API which is asynchronous and event-driven abstraction of
various transports such as a
NIO Channel.
A virtual
Channel
that helps wrapping a series of handlers to
unit test the handlers or use them in non-I/O context.Optimized transport for linux which uses EPOLL Edge-Triggered Mode
for maximal performance.
A channel registry which helps a user maintain the list of open
Channel
s and perform bulk operations on them.BSD specific transport.
NIO-based channel
API implementation - recommended for a large number of connections (>= 1000).
Old blocking I/O based channel API implementation - recommended for
a small number of connections (< 1000).
Implementations and API for
Channel
pools.Abstract SCTP socket interfaces which extend the core channel API.
NIO-based SCTP Channel
API implementation - recommended for a large number of connections (>= 1000).
Old blocking I/O based SCTP channel API implementation - recommended for
a small number of connections (< 1000).
Abstract TCP and UDP socket interfaces which extend the core channel API.
NIO-based socket channel
API implementation - recommended for a large number of connections (>= 1000).
Old blocking I/O based socket channel API implementation - recommended for
a small number of connections (< 1000).
Encoder, decoder, handshakers and their related message types for
Web Socket data frames.
Handlers for sending and receiving HTTP/2 frames.
Encoder, decoder, session handler and their related message types for the SPDY protocol.
Package to filter IP addresses (allow/deny).
Writes very large data stream asynchronously neither spending a lot of
memory nor getting
OutOfMemoryError
.Adds support for read and write timeout and idle connection notification
using a
Timer
.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 ChannelFutureModifier and TypeClassDescription(package private) static final class
Methods in io.netty.bootstrap that return ChannelFutureModifier and TypeMethodDescriptionAbstractBootstrap.bind()
Create a newChannel
and bind it.AbstractBootstrap.bind
(int inetPort) Create a newChannel
and bind it.Create a newChannel
and bind it.AbstractBootstrap.bind
(InetAddress inetHost, int inetPort) Create a newChannel
and bind it.AbstractBootstrap.bind
(SocketAddress localAddress) Create a newChannel
and bind it.Bootstrap.connect()
Connect aChannel
to the remote peer.Connect aChannel
to the remote peer.Bootstrap.connect
(InetAddress inetHost, int inetPort) Connect aChannel
to the remote peer.Bootstrap.connect
(SocketAddress remoteAddress) Connect aChannel
to the remote peer.Bootstrap.connect
(SocketAddress remoteAddress, SocketAddress localAddress) Connect aChannel
to the remote peer.private ChannelFuture
AbstractBootstrap.doBind
(SocketAddress localAddress) private ChannelFuture
Bootstrap.doResolveAndConnect
(SocketAddress remoteAddress, SocketAddress localAddress) private ChannelFuture
Bootstrap.doResolveAndConnect0
(Channel channel, SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) (package private) final ChannelFuture
AbstractBootstrap.initAndRegister()
AbstractBootstrap.register()
Methods in io.netty.bootstrap with parameters of type ChannelFutureModifier and TypeMethodDescriptionprivate static void
AbstractBootstrap.doBind0
(ChannelFuture regFuture, Channel channel, SocketAddress localAddress, ChannelPromise promise) -
Uses of ChannelFuture in io.netty.channel
Subinterfaces of ChannelFuture in io.netty.channelModifier and TypeInterfaceDescriptioninterface
An specialChannelFuture
which is used to indicate theFileRegion
transfer progressinterface
SpecialChannelPromise
which will be notified once the associated bytes is transferring.interface
SpecialChannelFuture
which is writable.Classes in io.netty.channel that implement ChannelFutureModifier and TypeClassDescription(package private) static final class
(package private) class
A skeletalChannelFuture
implementation which represents aChannelFuture
which has been completed already.class
The defaultChannelProgressivePromise
implementation.class
The defaultChannelPromise
implementation.final class
(package private) final class
TheCompleteChannelFuture
which is failed already.(package private) final class
TheCompleteChannelFuture
which is succeeded already.final class
Fields in io.netty.channel declared as ChannelFutureModifier and TypeFieldDescriptionprivate ChannelFuture
AbstractChannelHandlerContext.succeededFuture
private final ChannelFuture
DefaultChannelPipeline.succeededFuture
Methods in io.netty.channel that return ChannelFutureModifier and TypeMethodDescriptionChannelFuture.addListener
(GenericFutureListener<? extends Future<? super Void>> listener) CompleteChannelFuture.addListener
(GenericFutureListener<? extends Future<? super Void>> listener) ChannelFuture.addListeners
(GenericFutureListener<? extends Future<? super Void>>... listeners) CompleteChannelFuture.addListeners
(GenericFutureListener<? extends Future<? super Void>>... listeners) ChannelFuture.await()
CompleteChannelFuture.await()
ChannelFuture.awaitUninterruptibly()
CompleteChannelFuture.awaitUninterruptibly()
AbstractChannel.bind
(SocketAddress localAddress) AbstractChannel.bind
(SocketAddress localAddress, ChannelPromise promise) AbstractChannelHandlerContext.bind
(SocketAddress localAddress) AbstractChannelHandlerContext.bind
(SocketAddress localAddress, ChannelPromise promise) ChannelOutboundInvoker.bind
(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.ChannelOutboundInvoker.bind
(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.CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.bind
(SocketAddress localAddress) CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.bind
(SocketAddress localAddress, ChannelPromise promise) final ChannelFuture
DefaultChannelPipeline.bind
(SocketAddress localAddress) final ChannelFuture
DefaultChannelPipeline.bind
(SocketAddress localAddress, ChannelPromise promise) AbstractChannel.close()
AbstractChannel.close
(ChannelPromise promise) AbstractChannelHandlerContext.close()
AbstractChannelHandlerContext.close
(ChannelPromise promise) ChannelOutboundInvoker.close()
Request to close theChannel
and notify theChannelFuture
once the operation completes, either because the operation was successful or because of an error.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.CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.close()
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.close
(ChannelPromise promise) final ChannelFuture
DefaultChannelPipeline.close()
final ChannelFuture
DefaultChannelPipeline.close
(ChannelPromise promise) AbstractChannel.closeFuture()
Channel.closeFuture()
Returns theChannelFuture
which will be notified when this channel is closed.AbstractChannel.connect
(SocketAddress remoteAddress) AbstractChannel.connect
(SocketAddress remoteAddress, ChannelPromise promise) AbstractChannel.connect
(SocketAddress remoteAddress, SocketAddress localAddress) AbstractChannel.connect
(SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) AbstractChannelHandlerContext.connect
(SocketAddress remoteAddress) AbstractChannelHandlerContext.connect
(SocketAddress remoteAddress, ChannelPromise promise) AbstractChannelHandlerContext.connect
(SocketAddress remoteAddress, SocketAddress localAddress) AbstractChannelHandlerContext.connect
(SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) ChannelOutboundInvoker.connect
(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.ChannelOutboundInvoker.connect
(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.ChannelOutboundInvoker.connect
(SocketAddress remoteAddress, 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.ChannelOutboundInvoker.connect
(SocketAddress remoteAddress, 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.CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.connect
(SocketAddress remoteAddress) CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.connect
(SocketAddress remoteAddress, ChannelPromise promise) CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.connect
(SocketAddress remoteAddress, SocketAddress localAddress) CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.connect
(SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) final ChannelFuture
DefaultChannelPipeline.connect
(SocketAddress remoteAddress) final ChannelFuture
DefaultChannelPipeline.connect
(SocketAddress remoteAddress, ChannelPromise promise) final ChannelFuture
DefaultChannelPipeline.connect
(SocketAddress remoteAddress, SocketAddress localAddress) final ChannelFuture
DefaultChannelPipeline.connect
(SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) AbstractChannel.deregister()
AbstractChannel.deregister
(ChannelPromise promise) AbstractChannelHandlerContext.deregister()
AbstractChannelHandlerContext.deregister
(ChannelPromise promise) 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.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.CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.deregister()
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.deregister
(ChannelPromise promise) final ChannelFuture
DefaultChannelPipeline.deregister()
final ChannelFuture
DefaultChannelPipeline.deregister
(ChannelPromise promise) AbstractChannel.disconnect()
AbstractChannel.disconnect
(ChannelPromise promise) AbstractChannelHandlerContext.disconnect()
AbstractChannelHandlerContext.disconnect
(ChannelPromise promise) 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.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.CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.disconnect()
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.disconnect
(ChannelPromise promise) final ChannelFuture
DefaultChannelPipeline.disconnect()
final ChannelFuture
DefaultChannelPipeline.disconnect
(ChannelPromise promise) AbstractChannel.newFailedFuture
(Throwable cause) AbstractChannelHandlerContext.newFailedFuture
(Throwable cause) ChannelOutboundInvoker.newFailedFuture
(Throwable cause) Create a newChannelFuture
which is marked as failed already.CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.newFailedFuture
(Throwable cause) final ChannelFuture
DefaultChannelPipeline.newFailedFuture
(Throwable cause) AbstractChannel.newSucceededFuture()
AbstractChannelHandlerContext.newSucceededFuture()
ChannelOutboundInvoker.newSucceededFuture()
Create a newChannelFuture
which is marked as succeeded already.CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.newSucceededFuture()
final ChannelFuture
DefaultChannelPipeline.newSucceededFuture()
EventLoopGroup.register
(ChannelPromise promise) EventLoopGroup.register
(Channel channel, ChannelPromise promise) Deprecated.MultithreadEventLoopGroup.register
(ChannelPromise promise) MultithreadEventLoopGroup.register
(Channel channel, ChannelPromise promise) Deprecated.SingleThreadEventLoop.register
(ChannelPromise promise) SingleThreadEventLoop.register
(Channel channel, ChannelPromise promise) Deprecated.ThreadPerChannelEventLoop.register
(ChannelPromise promise) Deprecated.ThreadPerChannelEventLoop.register
(Channel channel, ChannelPromise promise) Deprecated.Deprecated.ThreadPerChannelEventLoopGroup.register
(ChannelPromise promise) Deprecated.ThreadPerChannelEventLoopGroup.register
(Channel channel, ChannelPromise promise) Deprecated.PendingWriteQueue.removeAndWrite()
Removes a pending write operation and performs it viaChannelOutboundInvoker.write(Object, ChannelPromise)
.PendingWriteQueue.removeAndWriteAll()
Remove all pending write operation and performs them viaChannelOutboundInvoker.write(Object, ChannelPromise)
.ChannelFuture.removeListener
(GenericFutureListener<? extends Future<? super Void>> listener) CompleteChannelFuture.removeListener
(GenericFutureListener<? extends Future<? super Void>> listener) ChannelFuture.removeListeners
(GenericFutureListener<? extends Future<? super Void>>... listeners) CompleteChannelFuture.removeListeners
(GenericFutureListener<? extends Future<? super Void>>... listeners) ChannelFuture.sync()
CompleteChannelFuture.sync()
FailedChannelFuture.sync()
ChannelFuture.syncUninterruptibly()
CompleteChannelFuture.syncUninterruptibly()
FailedChannelFuture.syncUninterruptibly()
AbstractChannel.write
(Object msg, ChannelPromise promise) AbstractChannelHandlerContext.write
(Object msg, ChannelPromise promise) Request to write a message via thisChannelHandlerContext
through theChannelPipeline
.ChannelOutboundInvoker.write
(Object msg, ChannelPromise promise) Request to write a message via thisChannelHandlerContext
through theChannelPipeline
.CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.write
(Object msg, ChannelPromise promise) final ChannelFuture
final ChannelFuture
DefaultChannelPipeline.write
(Object msg, ChannelPromise promise) AbstractChannel.writeAndFlush
(Object msg) AbstractChannel.writeAndFlush
(Object msg, ChannelPromise promise) AbstractChannelHandlerContext.writeAndFlush
(Object msg) AbstractChannelHandlerContext.writeAndFlush
(Object msg, ChannelPromise promise) ChannelOutboundInvoker.writeAndFlush
(Object msg) Shortcut for callChannelOutboundInvoker.write(Object)
andChannelOutboundInvoker.flush()
.ChannelOutboundInvoker.writeAndFlush
(Object msg, ChannelPromise promise) Shortcut for callChannelOutboundInvoker.write(Object, ChannelPromise)
andChannelOutboundInvoker.flush()
.CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.writeAndFlush
(Object msg) CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.writeAndFlush
(Object msg, ChannelPromise promise) final ChannelFuture
DefaultChannelPipeline.writeAndFlush
(Object msg) final ChannelFuture
DefaultChannelPipeline.writeAndFlush
(Object msg, ChannelPromise promise) Methods in io.netty.channel with parameters of type ChannelFutureModifier and TypeMethodDescriptionvoid
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 ChannelFutureModifier and TypeMethodDescriptionEmbeddedChannel.bind
(SocketAddress localAddress) EmbeddedChannel.bind
(SocketAddress localAddress, ChannelPromise promise) private ChannelFuture
EmbeddedChannel.checkException
(ChannelPromise promise) Checks for the presence of anException
.final ChannelFuture
EmbeddedChannel.close()
final ChannelFuture
EmbeddedChannel.close
(ChannelPromise promise) EmbeddedChannel.connect
(SocketAddress remoteAddress) EmbeddedChannel.connect
(SocketAddress remoteAddress, ChannelPromise promise) EmbeddedChannel.connect
(SocketAddress remoteAddress, SocketAddress localAddress) EmbeddedChannel.connect
(SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) EmbeddedChannel.deregister()
EmbeddedChannel.deregister
(ChannelPromise promise) final ChannelFuture
EmbeddedChannel.disconnect()
final ChannelFuture
EmbeddedChannel.disconnect
(ChannelPromise promise) private ChannelFuture
EmbeddedChannel.flushInbound
(boolean recordException, ChannelPromise promise) EmbeddedEventLoop.register
(ChannelPromise promise) EmbeddedEventLoop.register
(Channel channel, ChannelPromise promise) Deprecated.EmbeddedChannel.write
(Object msg, ChannelPromise promise) EmbeddedChannel.writeAndFlush
(Object msg) EmbeddedChannel.writeAndFlush
(Object msg, ChannelPromise promise) EmbeddedChannel.writeOneInbound
(Object msg) Writes one message to the inbound of thisChannel
and does not flush it.EmbeddedChannel.writeOneInbound
(Object msg, ChannelPromise promise) Writes one message to the inbound of thisChannel
and does not flush it.EmbeddedChannel.writeOneOutbound
(Object msg) Writes one message to the outbound of thisChannel
and does not flush it.EmbeddedChannel.writeOneOutbound
(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 ChannelFutureModifier and TypeMethodDescriptionprivate void
EmbeddedChannel.recordException
(ChannelFuture future) -
Uses of ChannelFuture in io.netty.channel.epoll
Methods in io.netty.channel.epoll that return ChannelFutureModifier and TypeMethodDescriptionEpollDatagramChannel.block
(InetAddress multicastAddress, InetAddress sourceToBlock) EpollDatagramChannel.block
(InetAddress multicastAddress, InetAddress sourceToBlock, ChannelPromise promise) EpollDatagramChannel.block
(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress sourceToBlock) EpollDatagramChannel.block
(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress sourceToBlock, ChannelPromise promise) EpollDatagramChannel.joinGroup
(InetAddress multicastAddress) EpollDatagramChannel.joinGroup
(InetAddress multicastAddress, ChannelPromise promise) EpollDatagramChannel.joinGroup
(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source) EpollDatagramChannel.joinGroup
(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source, ChannelPromise promise) EpollDatagramChannel.joinGroup
(InetSocketAddress multicastAddress, NetworkInterface networkInterface) EpollDatagramChannel.joinGroup
(InetSocketAddress multicastAddress, NetworkInterface networkInterface, ChannelPromise promise) EpollDatagramChannel.leaveGroup
(InetAddress multicastAddress) EpollDatagramChannel.leaveGroup
(InetAddress multicastAddress, ChannelPromise promise) EpollDatagramChannel.leaveGroup
(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source) EpollDatagramChannel.leaveGroup
(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source, ChannelPromise promise) EpollDatagramChannel.leaveGroup
(InetSocketAddress multicastAddress, NetworkInterface networkInterface) EpollDatagramChannel.leaveGroup
(InetSocketAddress multicastAddress, NetworkInterface networkInterface, ChannelPromise promise) AbstractEpollStreamChannel.shutdown()
AbstractEpollStreamChannel.shutdown
(ChannelPromise promise) AbstractEpollStreamChannel.shutdownInput()
AbstractEpollStreamChannel.shutdownInput
(ChannelPromise promise) AbstractEpollStreamChannel.shutdownOutput()
AbstractEpollStreamChannel.shutdownOutput
(ChannelPromise promise) final ChannelFuture
AbstractEpollStreamChannel.spliceTo
(AbstractEpollStreamChannel ch, int len) Splice from thisAbstractEpollStreamChannel
to anotherAbstractEpollStreamChannel
.final ChannelFuture
AbstractEpollStreamChannel.spliceTo
(AbstractEpollStreamChannel ch, int len, ChannelPromise promise) Splice from thisAbstractEpollStreamChannel
to anotherAbstractEpollStreamChannel
.final ChannelFuture
AbstractEpollStreamChannel.spliceTo
(FileDescriptor ch, int offset, int len) Splice from thisAbstractEpollStreamChannel
to anotherFileDescriptor
.final 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 ChannelFutureModifier and TypeMethodDescriptionvoid
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 ChannelFutureModifier and TypeFieldDescriptionprivate static final Iterator
<ChannelFuture> VoidChannelGroupFuture.EMPTY
private final Map
<Channel, ChannelFuture> DefaultChannelGroupFuture.futures
Methods in io.netty.channel.group that return ChannelFutureModifier and TypeMethodDescriptionReturns theChannelFuture
of the individual I/O operation which is associated with the specifiedChannel
.Methods in io.netty.channel.group that return types with arguments of type ChannelFutureModifier and TypeMethodDescriptionChannelGroupFuture.iterator()
Returns theIterator
that enumerates allChannelFuture
s which are associated with this future.DefaultChannelGroupFuture.iterator()
VoidChannelGroupFuture.iterator()
Constructor parameters in io.netty.channel.group with type arguments of type ChannelFutureModifierConstructorDescription(package private)
DefaultChannelGroupFuture
(ChannelGroup group, Collection<ChannelFuture> futures, EventExecutor executor) Creates a new instance.(package private)
DefaultChannelGroupFuture
(ChannelGroup group, Map<Channel, ChannelFuture> futures, EventExecutor executor) -
Uses of ChannelFuture in io.netty.channel.kqueue
Methods in io.netty.channel.kqueue that return ChannelFutureModifier and TypeMethodDescriptionKQueueDatagramChannel.block
(InetAddress multicastAddress, InetAddress sourceToBlock) KQueueDatagramChannel.block
(InetAddress multicastAddress, InetAddress sourceToBlock, ChannelPromise promise) KQueueDatagramChannel.block
(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress sourceToBlock) KQueueDatagramChannel.block
(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress sourceToBlock, ChannelPromise promise) KQueueDatagramChannel.joinGroup
(InetAddress multicastAddress) KQueueDatagramChannel.joinGroup
(InetAddress multicastAddress, ChannelPromise promise) KQueueDatagramChannel.joinGroup
(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source) KQueueDatagramChannel.joinGroup
(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source, ChannelPromise promise) KQueueDatagramChannel.joinGroup
(InetSocketAddress multicastAddress, NetworkInterface networkInterface) KQueueDatagramChannel.joinGroup
(InetSocketAddress multicastAddress, NetworkInterface networkInterface, ChannelPromise promise) KQueueDatagramChannel.leaveGroup
(InetAddress multicastAddress) KQueueDatagramChannel.leaveGroup
(InetAddress multicastAddress, ChannelPromise promise) KQueueDatagramChannel.leaveGroup
(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source) KQueueDatagramChannel.leaveGroup
(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source, ChannelPromise promise) KQueueDatagramChannel.leaveGroup
(InetSocketAddress multicastAddress, NetworkInterface networkInterface) KQueueDatagramChannel.leaveGroup
(InetSocketAddress multicastAddress, NetworkInterface networkInterface, ChannelPromise promise) AbstractKQueueStreamChannel.shutdown()
AbstractKQueueStreamChannel.shutdown
(ChannelPromise promise) AbstractKQueueStreamChannel.shutdownInput()
AbstractKQueueStreamChannel.shutdownInput
(ChannelPromise promise) AbstractKQueueStreamChannel.shutdownOutput()
AbstractKQueueStreamChannel.shutdownOutput
(ChannelPromise promise) Methods in io.netty.channel.kqueue with parameters of type ChannelFutureModifier and TypeMethodDescriptionprivate 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 ChannelFutureModifier and TypeMethodDescriptionprotected 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 ChannelFutureModifier and TypeMethodDescriptionprotected 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 ChannelFutureModifier and TypeMethodDescriptionprotected ChannelFuture
SimpleChannelPool.connectChannel
(Bootstrap bs) Bootstrap a newChannel
.Methods in io.netty.channel.pool with parameters of type ChannelFutureModifier and TypeMethodDescriptionprivate void
SimpleChannelPool.notifyConnect
(ChannelFuture future, Promise<Channel> promise) -
Uses of ChannelFuture in io.netty.channel.sctp
Methods in io.netty.channel.sctp that return ChannelFutureModifier and TypeMethodDescriptionSctpChannel.bindAddress
(InetAddress localAddress) Bind a address to the already bound channel to enable multi-homing.SctpChannel.bindAddress
(InetAddress localAddress, ChannelPromise promise) Bind a address to the already bound channel to enable multi-homing.SctpServerChannel.bindAddress
(InetAddress localAddress) Bind a address to the already bound channel to enable multi-homing.SctpServerChannel.bindAddress
(InetAddress localAddress, ChannelPromise promise) Bind a address to the already bound channel to enable multi-homing.SctpChannel.unbindAddress
(InetAddress localAddress) Unbind the address from channel's multi-homing address list.SctpChannel.unbindAddress
(InetAddress localAddress, ChannelPromise promise) Unbind the address from channel's multi-homing address list.SctpServerChannel.unbindAddress
(InetAddress localAddress) Unbind the address from channel's multi-homing address list.SctpServerChannel.unbindAddress
(InetAddress localAddress, ChannelPromise promise) Unbind the address from channel's multi-homing address list. -
Uses of ChannelFuture in io.netty.channel.sctp.nio
Methods in io.netty.channel.sctp.nio that return ChannelFutureModifier and TypeMethodDescriptionNioSctpChannel.bindAddress
(InetAddress localAddress) NioSctpChannel.bindAddress
(InetAddress localAddress, ChannelPromise promise) NioSctpServerChannel.bindAddress
(InetAddress localAddress) NioSctpServerChannel.bindAddress
(InetAddress localAddress, ChannelPromise promise) NioSctpChannel.unbindAddress
(InetAddress localAddress) NioSctpChannel.unbindAddress
(InetAddress localAddress, ChannelPromise promise) NioSctpServerChannel.unbindAddress
(InetAddress localAddress) NioSctpServerChannel.unbindAddress
(InetAddress localAddress, ChannelPromise promise) -
Uses of ChannelFuture in io.netty.channel.sctp.oio
Methods in io.netty.channel.sctp.oio that return ChannelFutureModifier and TypeMethodDescriptionOioSctpChannel.bindAddress
(InetAddress localAddress) Deprecated.OioSctpChannel.bindAddress
(InetAddress localAddress, ChannelPromise promise) Deprecated.OioSctpServerChannel.bindAddress
(InetAddress localAddress) Deprecated.OioSctpServerChannel.bindAddress
(InetAddress localAddress, ChannelPromise promise) Deprecated.OioSctpChannel.unbindAddress
(InetAddress localAddress) Deprecated.OioSctpChannel.unbindAddress
(InetAddress localAddress, ChannelPromise promise) Deprecated.OioSctpServerChannel.unbindAddress
(InetAddress localAddress) Deprecated.OioSctpServerChannel.unbindAddress
(InetAddress localAddress, ChannelPromise promise) Deprecated. -
Uses of ChannelFuture in io.netty.channel.socket
Methods in io.netty.channel.socket that return ChannelFutureModifier and TypeMethodDescriptionDatagramChannel.block
(InetAddress multicastAddress, InetAddress sourceToBlock) Block the given sourceToBlock address for the given multicastAddress and notifies theChannelFuture
once the operation completes.DatagramChannel.block
(InetAddress multicastAddress, InetAddress sourceToBlock, ChannelPromise future) Block the given sourceToBlock address for the given multicastAddress and notifies theChannelFuture
once the operation completes.DatagramChannel.block
(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress sourceToBlock) Block the given sourceToBlock address for the given multicastAddress on the given networkInterface and notifies theChannelFuture
once the operation completes.DatagramChannel.block
(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress sourceToBlock, ChannelPromise future) Block the given sourceToBlock address for the given multicastAddress on the given networkInterface and notifies theChannelFuture
once the operation completes.DatagramChannel.joinGroup
(InetAddress multicastAddress) Joins a multicast group and notifies theChannelFuture
once the operation completes.DatagramChannel.joinGroup
(InetAddress multicastAddress, ChannelPromise future) Joins a multicast group and notifies theChannelFuture
once the operation completes.DatagramChannel.joinGroup
(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source) Joins the specified multicast group at the specified interface and notifies theChannelFuture
once the operation completes.DatagramChannel.joinGroup
(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source, ChannelPromise future) Joins the specified multicast group at the specified interface and notifies theChannelFuture
once the operation completes.DatagramChannel.joinGroup
(InetSocketAddress multicastAddress, NetworkInterface networkInterface) Joins the specified multicast group at the specified interface and notifies theChannelFuture
once the operation completes.DatagramChannel.joinGroup
(InetSocketAddress multicastAddress, NetworkInterface networkInterface, ChannelPromise future) Joins the specified multicast group at the specified interface and notifies theChannelFuture
once the operation completes.DatagramChannel.leaveGroup
(InetAddress multicastAddress) Leaves a multicast group and notifies theChannelFuture
once the operation completes.DatagramChannel.leaveGroup
(InetAddress multicastAddress, ChannelPromise future) Leaves a multicast group and notifies theChannelFuture
once the operation completes.DatagramChannel.leaveGroup
(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source) Leave the specified multicast group at the specified interface using the specified source and notifies theChannelFuture
once the operation completes.DatagramChannel.leaveGroup
(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source, ChannelPromise future) Leave the specified multicast group at the specified interface using the specified source and notifies theChannelFuture
once the operation completes.DatagramChannel.leaveGroup
(InetSocketAddress multicastAddress, NetworkInterface networkInterface) Leaves a multicast group on a specified local interface and notifies theChannelFuture
once the operation completes.DatagramChannel.leaveGroup
(InetSocketAddress multicastAddress, NetworkInterface networkInterface, ChannelPromise future) Leaves a multicast group on a specified local interface and notifies theChannelFuture
once the operation completes.DuplexChannel.shutdown()
Will shutdown the input and output sides of this channel.DuplexChannel.shutdown
(ChannelPromise promise) Will shutdown the input and output sides of this channel.DuplexChannel.shutdownInput()
DuplexChannel.shutdownInput
(ChannelPromise promise) Will shutdown the input and notifyChannelPromise
.DuplexChannel.shutdownOutput()
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 ChannelFutureModifier and TypeMethodDescriptionNioDatagramChannel.block
(InetAddress multicastAddress, InetAddress sourceToBlock) Block the given sourceToBlock address for the given multicastAddressNioDatagramChannel.block
(InetAddress multicastAddress, InetAddress sourceToBlock, ChannelPromise promise) Block the given sourceToBlock address for the given multicastAddressNioDatagramChannel.block
(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress sourceToBlock) Block the given sourceToBlock address for the given multicastAddress on the given networkInterfaceNioDatagramChannel.block
(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress sourceToBlock, ChannelPromise promise) Block the given sourceToBlock address for the given multicastAddress on the given networkInterfaceNioDatagramChannel.joinGroup
(InetAddress multicastAddress) NioDatagramChannel.joinGroup
(InetAddress multicastAddress, ChannelPromise promise) NioDatagramChannel.joinGroup
(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source) NioDatagramChannel.joinGroup
(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source, ChannelPromise promise) NioDatagramChannel.joinGroup
(InetSocketAddress multicastAddress, NetworkInterface networkInterface) NioDatagramChannel.joinGroup
(InetSocketAddress multicastAddress, NetworkInterface networkInterface, ChannelPromise promise) NioDatagramChannel.leaveGroup
(InetAddress multicastAddress) NioDatagramChannel.leaveGroup
(InetAddress multicastAddress, ChannelPromise promise) NioDatagramChannel.leaveGroup
(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source) NioDatagramChannel.leaveGroup
(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source, ChannelPromise promise) NioDatagramChannel.leaveGroup
(InetSocketAddress multicastAddress, NetworkInterface networkInterface) NioDatagramChannel.leaveGroup
(InetSocketAddress multicastAddress, NetworkInterface networkInterface, ChannelPromise promise) NioDomainSocketChannel.shutdown()
NioDomainSocketChannel.shutdown
(ChannelPromise promise) NioSocketChannel.shutdown()
NioSocketChannel.shutdown
(ChannelPromise promise) NioDomainSocketChannel.shutdownInput()
NioDomainSocketChannel.shutdownInput
(ChannelPromise promise) NioSocketChannel.shutdownInput()
NioSocketChannel.shutdownInput
(ChannelPromise promise) NioDomainSocketChannel.shutdownOutput()
NioDomainSocketChannel.shutdownOutput
(ChannelPromise promise) NioSocketChannel.shutdownOutput()
NioSocketChannel.shutdownOutput
(ChannelPromise promise) Methods in io.netty.channel.socket.nio with parameters of type ChannelFutureModifier and TypeMethodDescriptionprivate static void
NioDomainSocketChannel.shutdownDone
(ChannelFuture shutdownOutputFuture, ChannelFuture shutdownInputFuture, ChannelPromise promise) private static void
NioSocketChannel.shutdownDone
(ChannelFuture shutdownOutputFuture, ChannelFuture shutdownInputFuture, ChannelPromise promise) private void
NioDomainSocketChannel.shutdownOutputDone
(ChannelFuture shutdownOutputFuture, 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 ChannelFutureModifier and TypeMethodDescriptionOioDatagramChannel.block
(InetAddress multicastAddress, InetAddress sourceToBlock) Deprecated.OioDatagramChannel.block
(InetAddress multicastAddress, InetAddress sourceToBlock, ChannelPromise promise) Deprecated.OioDatagramChannel.block
(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress sourceToBlock) Deprecated.OioDatagramChannel.block
(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress sourceToBlock, ChannelPromise promise) Deprecated.OioDatagramChannel.joinGroup
(InetAddress multicastAddress) Deprecated.OioDatagramChannel.joinGroup
(InetAddress multicastAddress, ChannelPromise promise) Deprecated.OioDatagramChannel.joinGroup
(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source) Deprecated.OioDatagramChannel.joinGroup
(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source, ChannelPromise promise) Deprecated.OioDatagramChannel.joinGroup
(InetSocketAddress multicastAddress, NetworkInterface networkInterface) Deprecated.OioDatagramChannel.joinGroup
(InetSocketAddress multicastAddress, NetworkInterface networkInterface, ChannelPromise promise) Deprecated.OioDatagramChannel.leaveGroup
(InetAddress multicastAddress) Deprecated.OioDatagramChannel.leaveGroup
(InetAddress multicastAddress, ChannelPromise promise) Deprecated.OioDatagramChannel.leaveGroup
(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source) Deprecated.OioDatagramChannel.leaveGroup
(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source, ChannelPromise promise) Deprecated.OioDatagramChannel.leaveGroup
(InetSocketAddress multicastAddress, NetworkInterface networkInterface) Deprecated.OioDatagramChannel.leaveGroup
(InetSocketAddress multicastAddress, NetworkInterface networkInterface, ChannelPromise promise) Deprecated.OioSocketChannel.shutdown()
Deprecated.OioSocketChannel.shutdown
(ChannelPromise promise) Deprecated.OioSocketChannel.shutdownInput()
Deprecated.OioSocketChannel.shutdownInput
(ChannelPromise promise) Deprecated.OioSocketChannel.shutdownOutput()
Deprecated.OioSocketChannel.shutdownOutput
(ChannelPromise promise) Deprecated.Methods in io.netty.channel.socket.oio with parameters of type ChannelFutureModifier and TypeMethodDescriptionprivate 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 ChannelFutureModifier and TypeMethodDescriptionBzip2Encoder.close()
Close thisBzip2Encoder
and so finish the encoding.Bzip2Encoder.close
(ChannelPromise promise) Close thisBzip2Encoder
and so finish the encoding.JdkZlibEncoder.close()
JdkZlibEncoder.close
(ChannelPromise promise) JZlibEncoder.close()
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 ChannelFutureModifier and TypeMethodDescription(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 ChannelFutureModifier and TypeMethodDescriptionWebSocketClientHandshaker.close
(ChannelHandlerContext ctx, CloseWebSocketFrame frame) Performs the closing handshakeWebSocketClientHandshaker.close
(ChannelHandlerContext ctx, CloseWebSocketFrame frame, ChannelPromise promise) Performs the closing handshakeWebSocketClientHandshaker.close
(Channel channel, CloseWebSocketFrame frame) Performs the closing handshake.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)
.WebSocketServerHandshaker.close
(ChannelHandlerContext ctx, CloseWebSocketFrame frame) Performs the closing handshake.WebSocketServerHandshaker.close
(ChannelHandlerContext ctx, CloseWebSocketFrame frame, ChannelPromise promise) Performs the closing handshake.WebSocketServerHandshaker.close
(Channel channel, CloseWebSocketFrame frame) Performs the closing handshake.WebSocketServerHandshaker.close
(Channel channel, CloseWebSocketFrame frame, ChannelPromise promise) Performs the closing handshake.WebSocketServerHandshaker00.close
(ChannelHandlerContext ctx, CloseWebSocketFrame frame, ChannelPromise promise) Echo back the closing frameWebSocketServerHandshaker00.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.Begins the opening handshakefinal ChannelFuture
WebSocketClientHandshaker.handshake
(Channel channel, ChannelPromise promise) Begins the opening handshakeWebSocketServerHandshaker.handshake
(Channel channel, FullHttpRequest req) Performs the opening handshake.final 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.WebSocketServerHandshaker.handshake
(Channel channel, HttpRequest req) Performs the opening handshake.final 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.final ChannelFuture
WebSocketClientHandshaker.processHandshake
(Channel channel, HttpResponse response) Process the opening handshake initiated byWebSocketClientHandshaker.handshake(io.netty.channel.Channel)
}.final 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 ChannelFutureModifier and TypeClassDescription(package private) static final class
Provides the ability to associate the outcome of multipleChannelPromise
objects into a singleChannelPromise
object.Methods in io.netty.handler.codec.http2 that return ChannelFutureModifier and TypeMethodDescriptionAbstractHttp2StreamChannel.bind
(SocketAddress localAddress) AbstractHttp2StreamChannel.bind
(SocketAddress localAddress, ChannelPromise promise) AbstractHttp2StreamChannel.close()
AbstractHttp2StreamChannel.close
(ChannelPromise promise) AbstractHttp2StreamChannel.closeFuture()
AbstractHttp2StreamChannel.connect
(SocketAddress remoteAddress) AbstractHttp2StreamChannel.connect
(SocketAddress remoteAddress, ChannelPromise promise) AbstractHttp2StreamChannel.connect
(SocketAddress remoteAddress, SocketAddress localAddress) AbstractHttp2StreamChannel.connect
(SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) AbstractHttp2StreamChannel.deregister()
AbstractHttp2StreamChannel.deregister
(ChannelPromise promise) AbstractHttp2StreamChannel.disconnect()
AbstractHttp2StreamChannel.disconnect
(ChannelPromise promise) 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.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
.AbstractHttp2StreamChannel.newFailedFuture
(Throwable cause) AbstractHttp2StreamChannel.newSucceededFuture()
Http2ConnectionHandler.resetStream
(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise) private ChannelFuture
Http2ConnectionHandler.resetStream
(ChannelHandlerContext ctx, Http2Stream stream, long errorCode, ChannelPromise promise) 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
.AbstractHttp2StreamChannel.write
(Object msg, ChannelPromise promise) protected ChannelFuture
AbstractHttp2StreamChannel.write0
(ChannelHandlerContext ctx, Object msg) protected ChannelFuture
Http2MultiplexCodec.Http2MultiplexCodecStreamChannel.write0
(ChannelHandlerContext ctx, Object msg) AbstractHttp2StreamChannel.writeAndFlush
(Object msg) AbstractHttp2StreamChannel.writeAndFlush
(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.CompressorHttp2ConnectionEncoder.writeData
(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endOfStream, ChannelPromise promise) DecoratingHttp2FrameWriter.writeData
(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endStream, ChannelPromise promise) DefaultHttp2ConnectionEncoder.writeData
(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endOfStream, ChannelPromise promise) DefaultHttp2FrameWriter.writeData
(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endStream, ChannelPromise promise) Http2DataWriter.writeData
(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endStream, ChannelPromise promise) Writes aDATA
frame to the remote endpoint.Http2OutboundFrameLogger.writeData
(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endStream, ChannelPromise promise) StreamBufferingEncoder.writeData
(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endOfStream, ChannelPromise promise) DecoratingHttp2FrameWriter.writeFrame
(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf payload, ChannelPromise promise) DefaultHttp2ConnectionEncoder.writeFrame
(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf payload, ChannelPromise promise) DefaultHttp2FrameWriter.writeFrame
(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf payload, ChannelPromise promise) 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.Http2FrameWriter.writeFrame
(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf payload, ChannelPromise promise) Generic write method for any HTTP/2 frame.Http2OutboundFrameLogger.writeFrame
(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf payload, ChannelPromise promise) DecoratingHttp2FrameWriter.writeGoAway
(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData, ChannelPromise promise) DefaultHttp2ConnectionEncoder.writeGoAway
(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData, ChannelPromise promise) DefaultHttp2FrameWriter.writeGoAway
(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData, ChannelPromise promise) Http2FrameWriter.writeGoAway
(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData, ChannelPromise promise) Writes a GO_AWAY frame to the remote endpoint.Http2OutboundFrameLogger.writeGoAway
(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData, ChannelPromise promise) CompressorHttp2ConnectionEncoder.writeHeaders
(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream, ChannelPromise promise) CompressorHttp2ConnectionEncoder.writeHeaders
(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endOfStream, ChannelPromise promise) DecoratingHttp2FrameWriter.writeHeaders
(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream, ChannelPromise promise) DecoratingHttp2FrameWriter.writeHeaders
(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endStream, ChannelPromise promise) DefaultHttp2ConnectionEncoder.writeHeaders
(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream, ChannelPromise promise) DefaultHttp2ConnectionEncoder.writeHeaders
(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endOfStream, ChannelPromise promise) DefaultHttp2FrameWriter.writeHeaders
(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream, ChannelPromise promise) DefaultHttp2FrameWriter.writeHeaders
(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endStream, ChannelPromise promise) Http2FrameWriter.writeHeaders
(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream, ChannelPromise promise) Writes a HEADERS frame to the remote endpoint.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.Http2OutboundFrameLogger.writeHeaders
(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream, ChannelPromise promise) Http2OutboundFrameLogger.writeHeaders
(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endStream, ChannelPromise promise) StreamBufferingEncoder.writeHeaders
(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream, ChannelPromise promise) 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 ChannelFuture
DefaultHttp2FrameWriter.writeHeadersInternal
(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream, boolean hasPriority, int streamDependency, short weight, boolean exclusive, ChannelPromise promise) DecoratingHttp2FrameWriter.writePing
(ChannelHandlerContext ctx, boolean ack, long data, ChannelPromise promise) DefaultHttp2ConnectionEncoder.writePing
(ChannelHandlerContext ctx, boolean ack, long data, ChannelPromise promise) DefaultHttp2FrameWriter.writePing
(ChannelHandlerContext ctx, boolean ack, long data, ChannelPromise promise) Http2ControlFrameLimitEncoder.writePing
(ChannelHandlerContext ctx, boolean ack, long data, ChannelPromise promise) Http2FrameWriter.writePing
(ChannelHandlerContext ctx, boolean ack, long data, ChannelPromise promise) Writes a PING frame to the remote endpoint.Http2OutboundFrameLogger.writePing
(ChannelHandlerContext ctx, boolean ack, long data, ChannelPromise promise) DecoratingHttp2FrameWriter.writePriority
(ChannelHandlerContext ctx, int streamId, int streamDependency, short weight, boolean exclusive, ChannelPromise promise) DefaultHttp2ConnectionEncoder.writePriority
(ChannelHandlerContext ctx, int streamId, int streamDependency, short weight, boolean exclusive, ChannelPromise promise) DefaultHttp2FrameWriter.writePriority
(ChannelHandlerContext ctx, int streamId, int streamDependency, short weight, boolean exclusive, ChannelPromise promise) Http2FrameWriter.writePriority
(ChannelHandlerContext ctx, int streamId, int streamDependency, short weight, boolean exclusive, ChannelPromise promise) Writes a PRIORITY frame to the remote endpoint.Http2OutboundFrameLogger.writePriority
(ChannelHandlerContext ctx, int streamId, int streamDependency, short weight, boolean exclusive, ChannelPromise promise) DecoratingHttp2FrameWriter.writePushPromise
(ChannelHandlerContext ctx, int streamId, int promisedStreamId, Http2Headers headers, int padding, ChannelPromise promise) DefaultHttp2ConnectionEncoder.writePushPromise
(ChannelHandlerContext ctx, int streamId, int promisedStreamId, Http2Headers headers, int padding, ChannelPromise promise) DefaultHttp2FrameWriter.writePushPromise
(ChannelHandlerContext ctx, int streamId, int promisedStreamId, Http2Headers headers, int padding, ChannelPromise promise) Http2FrameWriter.writePushPromise
(ChannelHandlerContext ctx, int streamId, int promisedStreamId, Http2Headers headers, int padding, ChannelPromise promise) Writes a PUSH_PROMISE frame to the remote endpoint.Http2OutboundFrameLogger.writePushPromise
(ChannelHandlerContext ctx, int streamId, int promisedStreamId, Http2Headers headers, int padding, ChannelPromise promise) DecoratingHttp2FrameWriter.writeRstStream
(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise) DefaultHttp2ConnectionEncoder.writeRstStream
(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise) DefaultHttp2FrameWriter.writeRstStream
(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise) Http2ControlFrameLimitEncoder.writeRstStream
(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise) Http2FrameWriter.writeRstStream
(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise) Writes a RST_STREAM frame to the remote endpoint.Http2OutboundFrameLogger.writeRstStream
(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise) StreamBufferingEncoder.writeRstStream
(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise) DecoratingHttp2FrameWriter.writeSettings
(ChannelHandlerContext ctx, Http2Settings settings, ChannelPromise promise) DefaultHttp2ConnectionEncoder.writeSettings
(ChannelHandlerContext ctx, Http2Settings settings, ChannelPromise promise) DefaultHttp2FrameWriter.writeSettings
(ChannelHandlerContext ctx, Http2Settings settings, ChannelPromise promise) Http2FrameWriter.writeSettings
(ChannelHandlerContext ctx, Http2Settings settings, ChannelPromise promise) Writes a SETTINGS frame to the remote endpoint.Http2OutboundFrameLogger.writeSettings
(ChannelHandlerContext ctx, Http2Settings settings, ChannelPromise promise) DecoratingHttp2FrameWriter.writeSettingsAck
(ChannelHandlerContext ctx, ChannelPromise promise) DefaultHttp2ConnectionEncoder.writeSettingsAck
(ChannelHandlerContext ctx, ChannelPromise promise) DefaultHttp2FrameWriter.writeSettingsAck
(ChannelHandlerContext ctx, ChannelPromise promise) Http2ControlFrameLimitEncoder.writeSettingsAck
(ChannelHandlerContext ctx, ChannelPromise promise) Http2FrameWriter.writeSettingsAck
(ChannelHandlerContext ctx, ChannelPromise promise) Writes a SETTINGS acknowledgment to the remote endpoint.Http2OutboundFrameLogger.writeSettingsAck
(ChannelHandlerContext ctx, ChannelPromise promise) StreamBufferingEncoder.writeSettingsAck
(ChannelHandlerContext ctx, ChannelPromise promise) DecoratingHttp2FrameWriter.writeWindowUpdate
(ChannelHandlerContext ctx, int streamId, int windowSizeIncrement, ChannelPromise promise) DefaultHttp2ConnectionEncoder.writeWindowUpdate
(ChannelHandlerContext ctx, int streamId, int windowSizeIncrement, ChannelPromise promise) DefaultHttp2FrameWriter.writeWindowUpdate
(ChannelHandlerContext ctx, int streamId, int windowSizeIncrement, ChannelPromise promise) Http2FrameWriter.writeWindowUpdate
(ChannelHandlerContext ctx, int streamId, int windowSizeIncrement, ChannelPromise promise) Writes a WINDOW_UPDATE frame to the remote endpoint.Http2OutboundFrameLogger.writeWindowUpdate
(ChannelHandlerContext ctx, int streamId, int windowSizeIncrement, ChannelPromise promise) private ChannelFuture
AbstractHttp2StreamChannel.Http2ChannelUnsafe.writeWindowUpdateFrame
(Http2WindowUpdateFrame windowUpdateFrame) Methods in io.netty.handler.codec.http2 with parameters of type ChannelFutureModifier and TypeMethodDescriptionprivate 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 ChannelFutureModifier and TypeMethodDescriptionprivate ChannelFuture
SpdySessionHandler.sendGoAwayFrame
(ChannelHandlerContext ctx, SpdySessionStatus status) Methods in io.netty.handler.codec.spdy with parameters of type ChannelFutureModifier and TypeMethodDescriptionprivate 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 ChannelFutureModifier and TypeMethodDescriptionprotected 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 ChannelFutureModifier and TypeMethodDescriptionSslHandler.close()
Deprecated.SslHandler.close
(ChannelPromise promise) Deprecated.SslHandler.closeOutbound()
Sends an SSLclose_notify
message to the specified channel and destroys the underlyingSSLEngine
.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 ChannelFutureModifier and TypeMethodDescriptionprivate 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 ChannelFutureModifier and TypeMethodDescriptionprivate 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 ChannelFutureModifier and TypeMethodDescriptionvoid
WriteTimeoutHandler.WriteTimeoutTask.operationComplete
(ChannelFuture future) -
Uses of ChannelFuture in io.netty.resolver.dns
Fields in io.netty.resolver.dns declared as ChannelFutureModifier and TypeFieldDescriptionprivate final ChannelFuture
DnsNameResolver.DnsResolveChannelPerResolverProvider.resolveChannelFuture
Methods in io.netty.resolver.dns that return ChannelFutureModifier and TypeMethodDescription<T> ChannelFuture
DnsNameResolver.DnsResolveChannelPerResolutionProvider.nextResolveChannel
(Future<T> resolutionFuture) <T> ChannelFuture
DnsNameResolver.DnsResolveChannelPerResolverProvider.nextResolveChannel
(Future<T> resolutionFuture) <T> ChannelFuture
DnsNameResolver.DnsResolveChannelProvider.nextResolveChannel
(Future<T> resolutionFuture) Return the nextChannelFuture
that contains theChannel
that should be used for resolving a chain of queries.private static ChannelFuture
DnsNameResolver.registerOrBind
(Bootstrap bootstrap, SocketAddress localAddress) private ChannelFuture
(package private) final 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 ChannelFutureModifier and TypeMethodDescriptionprivate void
DnsNameResolver.doResolveAllNow
(ChannelFuture f, String hostname, DnsRecord[] additionals, Promise<List<InetAddress>> promise, DnsCache resolveCache) private void
DnsNameResolver.doResolveNow
(ChannelFuture f, String hostname, DnsRecord[] additionals, Promise<InetAddress> promise, DnsCache resolveCache) private void
DnsQueryContext.onQueryWriteCompletion
(long queryTimeoutMillis, ChannelFuture writeFuture) void
BiDnsQueryLifecycleObserver.queryWritten
(InetSocketAddress dnsServerAddress, ChannelFuture future) void
DnsQueryLifecycleObserver.queryWritten
(InetSocketAddress dnsServerAddress, ChannelFuture future) The query has been written.void
LoggingDnsQueryLifecycleObserver.queryWritten
(InetSocketAddress dnsServerAddress, ChannelFuture future) void
NoopDnsQueryLifecycleObserver.queryWritten
(InetSocketAddress dnsServerAddress, ChannelFuture future) private void
DnsNameResolver.resolveAllNow
(ChannelFuture f, String hostname, DnsQuestion question, DnsRecord[] additionals, Promise<List<DnsRecord>> promise) private static UnknownHostException
DnsNameResolver.toException
(ChannelFuture f, String hostname, DnsQuestion question, DnsRecord[] additionals)
EventLoopGroup.register(ChannelPromise)
instead.