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
Channels 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 classMethods in io.netty.bootstrap that return ChannelFutureModifier and TypeMethodDescriptionAbstractBootstrap.bind()Create a newChanneland bind it.AbstractBootstrap.bind(int inetPort) Create a newChanneland bind it.Create a newChanneland bind it.AbstractBootstrap.bind(InetAddress inetHost, int inetPort) Create a newChanneland bind it.AbstractBootstrap.bind(SocketAddress localAddress) Create a newChanneland bind it.Bootstrap.connect()Connect aChannelto the remote peer.Connect aChannelto the remote peer.Bootstrap.connect(InetAddress inetHost, int inetPort) Connect aChannelto the remote peer.Bootstrap.connect(SocketAddress remoteAddress) Connect aChannelto the remote peer.Bootstrap.connect(SocketAddress remoteAddress, SocketAddress localAddress) Connect aChannelto the remote peer.private ChannelFutureAbstractBootstrap.doBind(SocketAddress localAddress) private ChannelFutureBootstrap.doResolveAndConnect(SocketAddress remoteAddress, SocketAddress localAddress) private ChannelFutureBootstrap.doResolveAndConnect0(Channel channel, SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) (package private) final ChannelFutureAbstractBootstrap.initAndRegister()AbstractBootstrap.register()Methods in io.netty.bootstrap with parameters of type ChannelFutureModifier and TypeMethodDescriptionprivate static voidAbstractBootstrap.doBind0(ChannelFuture regFuture, Channel channel, SocketAddress localAddress, ChannelPromise promise) -
Uses of ChannelFuture in io.netty.channel
Subinterfaces of ChannelFuture in io.netty.channelModifier and TypeInterfaceDescriptioninterfaceAn specialChannelFuturewhich is used to indicate theFileRegiontransfer progressinterfaceSpecialChannelPromisewhich will be notified once the associated bytes is transferring.interfaceSpecialChannelFuturewhich is writable.Classes in io.netty.channel that implement ChannelFutureModifier and TypeClassDescription(package private) static final class(package private) classA skeletalChannelFutureimplementation which represents aChannelFuturewhich has been completed already.classThe defaultChannelProgressivePromiseimplementation.classThe defaultChannelPromiseimplementation.final class(package private) final classTheCompleteChannelFuturewhich is failed already.(package private) final classTheCompleteChannelFuturewhich is succeeded already.final classFields in io.netty.channel declared as ChannelFutureModifier and TypeFieldDescriptionprivate ChannelFutureAbstractChannelHandlerContext.succeededFutureprivate final ChannelFutureDefaultChannelPipeline.succeededFutureMethods 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 givenSocketAddressand notify theChannelFutureonce 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 givenSocketAddressand notify theChannelFutureonce 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 ChannelFutureDefaultChannelPipeline.bind(SocketAddress localAddress) final ChannelFutureDefaultChannelPipeline.bind(SocketAddress localAddress, ChannelPromise promise) AbstractChannel.close()AbstractChannel.close(ChannelPromise promise) AbstractChannelHandlerContext.close()AbstractChannelHandlerContext.close(ChannelPromise promise) ChannelOutboundInvoker.close()Request to close theChanneland notify theChannelFutureonce the operation completes, either because the operation was successful or because of an error.ChannelOutboundInvoker.close(ChannelPromise promise) Request to close theChanneland notify theChannelFutureonce the operation completes, either because the operation was successful or because of an error.CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.close()CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.close(ChannelPromise promise) final ChannelFutureDefaultChannelPipeline.close()final ChannelFutureDefaultChannelPipeline.close(ChannelPromise promise) AbstractChannel.closeFuture()Channel.closeFuture()Returns theChannelFuturewhich 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 givenSocketAddressand notify theChannelFutureonce 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 givenSocketAddressand notify theChannelFutureonce 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 givenSocketAddresswhile bind to the localAddress and notify theChannelFutureonce 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 givenSocketAddresswhile bind to the localAddress and notify theChannelFutureonce 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 ChannelFutureDefaultChannelPipeline.connect(SocketAddress remoteAddress) final ChannelFutureDefaultChannelPipeline.connect(SocketAddress remoteAddress, ChannelPromise promise) final ChannelFutureDefaultChannelPipeline.connect(SocketAddress remoteAddress, SocketAddress localAddress) final ChannelFutureDefaultChannelPipeline.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 assignedEventExecutorand notify theChannelFutureonce the operation completes, either because the operation was successful or because of an error.ChannelOutboundInvoker.deregister(ChannelPromise promise) Request to deregister from the previous assignedEventExecutorand notify theChannelFutureonce the operation completes, either because the operation was successful or because of an error.CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.deregister()CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.deregister(ChannelPromise promise) final ChannelFutureDefaultChannelPipeline.deregister()final ChannelFutureDefaultChannelPipeline.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 theChannelFutureonce 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 theChannelFutureonce the operation completes, either because the operation was successful or because of an error.CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.disconnect()CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.disconnect(ChannelPromise promise) final ChannelFutureDefaultChannelPipeline.disconnect()final ChannelFutureDefaultChannelPipeline.disconnect(ChannelPromise promise) AbstractChannel.newFailedFuture(Throwable cause) AbstractChannelHandlerContext.newFailedFuture(Throwable cause) ChannelOutboundInvoker.newFailedFuture(Throwable cause) Create a newChannelFuturewhich is marked as failed already.CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.newFailedFuture(Throwable cause) final ChannelFutureDefaultChannelPipeline.newFailedFuture(Throwable cause) AbstractChannel.newSucceededFuture()AbstractChannelHandlerContext.newSucceededFuture()ChannelOutboundInvoker.newSucceededFuture()Create a newChannelFuturewhich is marked as succeeded already.CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.newSucceededFuture()final ChannelFutureDefaultChannelPipeline.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 thisChannelHandlerContextthrough theChannelPipeline.ChannelOutboundInvoker.write(Object msg, ChannelPromise promise) Request to write a message via thisChannelHandlerContextthrough theChannelPipeline.CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.write(Object msg, ChannelPromise promise) final ChannelFuturefinal ChannelFutureDefaultChannelPipeline.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 ChannelFutureDefaultChannelPipeline.writeAndFlush(Object msg) final ChannelFutureDefaultChannelPipeline.writeAndFlush(Object msg, ChannelPromise promise) Methods in io.netty.channel with parameters of type ChannelFutureModifier and TypeMethodDescriptionvoidDelegatingChannelPromiseNotifier.operationComplete(ChannelFuture future) private voidAbstractCoalescingBufferQueue.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 ChannelFutureEmbeddedChannel.checkException(ChannelPromise promise) Checks for the presence of anException.final ChannelFutureEmbeddedChannel.close()final ChannelFutureEmbeddedChannel.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 ChannelFutureEmbeddedChannel.disconnect()final ChannelFutureEmbeddedChannel.disconnect(ChannelPromise promise) private ChannelFutureEmbeddedChannel.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 thisChanneland does not flush it.EmbeddedChannel.writeOneInbound(Object msg, ChannelPromise promise) Writes one message to the inbound of thisChanneland does not flush it.EmbeddedChannel.writeOneOutbound(Object msg) Writes one message to the outbound of thisChanneland does not flush it.EmbeddedChannel.writeOneOutbound(Object msg, ChannelPromise promise) Writes one message to the outbound of thisChanneland does not flush it.Methods in io.netty.channel.embedded with parameters of type ChannelFutureModifier and TypeMethodDescriptionprivate voidEmbeddedChannel.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 ChannelFutureAbstractEpollStreamChannel.spliceTo(AbstractEpollStreamChannel ch, int len) Deprecated.Will be removed in the future.final ChannelFutureAbstractEpollStreamChannel.spliceTo(AbstractEpollStreamChannel ch, int len, ChannelPromise promise) Deprecated.will be removed in the future.final ChannelFutureAbstractEpollStreamChannel.spliceTo(FileDescriptor ch, int offset, int len) Deprecated.Will be removed in the future.final ChannelFutureAbstractEpollStreamChannel.spliceTo(FileDescriptor ch, int offset, int len, ChannelPromise promise) Deprecated.Will be removed in the future.Methods in io.netty.channel.epoll with parameters of type ChannelFutureModifier and TypeMethodDescriptionvoidAbstractEpollStreamChannel.SpliceInChannelTask.operationComplete(ChannelFuture future) private static voidAbstractEpollStreamChannel.shutdownDone(ChannelFuture shutdownOutputFuture, ChannelFuture shutdownInputFuture, ChannelPromise promise) private voidAbstractEpollStreamChannel.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.EMPTYprivate final Map<Channel, ChannelFuture> DefaultChannelGroupFuture.futuresMethods in io.netty.channel.group that return ChannelFutureModifier and TypeMethodDescriptionReturns theChannelFutureof 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 theIteratorthat enumerates allChannelFutures 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 voidAbstractKQueueStreamChannel.shutdownDone(ChannelFuture shutdownOutputFuture, ChannelFuture shutdownInputFuture, ChannelPromise promise) private voidAbstractKQueueStreamChannel.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 ChannelFutureAbstractNioByteChannel.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 ChannelFutureAbstractOioByteChannel.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 ChannelFutureSimpleChannelPool.connectChannel(Bootstrap bs) Bootstrap a newChannel.Methods in io.netty.channel.pool with parameters of type ChannelFutureModifier and TypeMethodDescriptionprivate voidSimpleChannelPool.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 theChannelFutureonce the operation completes.DatagramChannel.block(InetAddress multicastAddress, InetAddress sourceToBlock, ChannelPromise future) Block the given sourceToBlock address for the given multicastAddress and notifies theChannelFutureonce 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 theChannelFutureonce 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 theChannelFutureonce the operation completes.DatagramChannel.joinGroup(InetAddress multicastAddress) Joins a multicast group and notifies theChannelFutureonce the operation completes.DatagramChannel.joinGroup(InetAddress multicastAddress, ChannelPromise future) Joins a multicast group and notifies theChannelFutureonce the operation completes.DatagramChannel.joinGroup(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source) Joins the specified multicast group at the specified interface and notifies theChannelFutureonce the operation completes.DatagramChannel.joinGroup(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source, ChannelPromise future) Joins the specified multicast group at the specified interface and notifies theChannelFutureonce the operation completes.DatagramChannel.joinGroup(InetSocketAddress multicastAddress, NetworkInterface networkInterface) Joins the specified multicast group at the specified interface and notifies theChannelFutureonce the operation completes.DatagramChannel.joinGroup(InetSocketAddress multicastAddress, NetworkInterface networkInterface, ChannelPromise future) Joins the specified multicast group at the specified interface and notifies theChannelFutureonce the operation completes.DatagramChannel.leaveGroup(InetAddress multicastAddress) Leaves a multicast group and notifies theChannelFutureonce the operation completes.DatagramChannel.leaveGroup(InetAddress multicastAddress, ChannelPromise future) Leaves a multicast group and notifies theChannelFutureonce 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 theChannelFutureonce 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 theChannelFutureonce the operation completes.DatagramChannel.leaveGroup(InetSocketAddress multicastAddress, NetworkInterface networkInterface) Leaves a multicast group on a specified local interface and notifies theChannelFutureonce the operation completes.DatagramChannel.leaveGroup(InetSocketAddress multicastAddress, NetworkInterface networkInterface, ChannelPromise future) Leaves a multicast group on a specified local interface and notifies theChannelFutureonce 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 voidNioDomainSocketChannel.shutdownDone(ChannelFuture shutdownOutputFuture, ChannelFuture shutdownInputFuture, ChannelPromise promise) private static voidNioSocketChannel.shutdownDone(ChannelFuture shutdownOutputFuture, ChannelFuture shutdownInputFuture, ChannelPromise promise) private voidNioDomainSocketChannel.shutdownOutputDone(ChannelFuture shutdownOutputFuture, ChannelPromise promise) private voidNioSocketChannel.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 voidOioSocketChannel.shutdownDone(ChannelFuture shutdownOutputFuture, ChannelFuture shutdownInputFuture, ChannelPromise promise) Deprecated.private voidOioSocketChannel.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 thisBzip2Encoderand so finish the encoding.Bzip2Encoder.close(ChannelPromise promise) Close thisBzip2Encoderand so finish the encoding.JdkZlibEncoder.close()JdkZlibEncoder.close(ChannelPromise promise) JZlibEncoder.close()JZlibEncoder.close(ChannelPromise promise) abstract ChannelFutureZlibEncoder.close()Close thisZlibEncoderand so finish the encoding.abstract ChannelFutureZlibEncoder.close(ChannelPromise promise) Close thisZlibEncoderand so finish the encoding.private ChannelFutureBzip2Encoder.finishEncode(ChannelHandlerContext ctx, ChannelPromise promise) private ChannelFutureJdkZlibEncoder.finishEncode(ChannelHandlerContext ctx, ChannelPromise promise) private ChannelFutureJZlibEncoder.finishEncode(ChannelHandlerContext ctx, ChannelPromise promise) Methods in io.netty.handler.codec.compression with parameters of type ChannelFutureModifier and TypeMethodDescription(package private) static voidEncoderUtil.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 aChannelHandleryou 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 ChannelFutureWebSocketClientHandshaker.close0(ChannelOutboundInvoker invoker, Channel channel, CloseWebSocketFrame frame, ChannelPromise promise) private ChannelFutureWebSocketServerHandshaker.close0(ChannelOutboundInvoker invoker, CloseWebSocketFrame frame, ChannelPromise promise) (package private) ChannelFutureWebSocketClientProtocolHandshakeHandler.getHandshakeFuture()This method is visible for testing.Begins the opening handshakefinal ChannelFutureWebSocketClientHandshaker.handshake(Channel channel, ChannelPromise promise) Begins the opening handshakeWebSocketServerHandshaker.handshake(Channel channel, FullHttpRequest req) Performs the opening handshake.final ChannelFutureWebSocketServerHandshaker.handshake(Channel channel, FullHttpRequest req, HttpHeaders responseHeaders, ChannelPromise promise) Performs the opening handshake When call this method you MUST NOT retain theFullHttpRequestwhich is passed in.WebSocketServerHandshaker.handshake(Channel channel, HttpRequest req) Performs the opening handshake.final ChannelFutureWebSocketServerHandshaker.handshake(Channel channel, HttpRequest req, HttpHeaders responseHeaders, ChannelPromise promise) Performs the opening handshake When call this method you MUST NOT retain theHttpRequestwhich is passed in.final ChannelFutureWebSocketClientHandshaker.processHandshake(Channel channel, HttpResponse response) Process the opening handshake initiated byWebSocketClientHandshaker.handshake(io.netty.channel.Channel)}.final ChannelFutureWebSocketClientHandshaker.processHandshake(Channel channel, HttpResponse response, ChannelPromise promise) Process the opening handshake initiated byWebSocketClientHandshaker.handshake(io.netty.channel.Channel)}.static ChannelFutureWebSocketServerHandshakerFactory.sendUnsupportedVersionResponse(Channel channel) Return that we need cannot support the web socket versionstatic ChannelFutureWebSocketServerHandshakerFactory.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 classProvides the ability to associate the outcome of multipleChannelPromiseobjects into a singleChannelPromiseobject.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 ChannelFutureHttp2ConnectionHandler.goAway(ChannelHandlerContext ctx, Http2Exception cause, ChannelPromise promise) Close the remote endpoint with aGO_AWAYframe.Http2LifecycleManager.goAway(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData, ChannelPromise promise) Prevents the peer from creating streams and close the connection iferrorCodeis notHttp2Error.NO_ERROR.AbstractHttp2StreamChannel.newFailedFuture(Throwable cause) AbstractHttp2StreamChannel.newSucceededFuture()Http2ConnectionHandler.resetStream(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise) private ChannelFutureHttp2ConnectionHandler.resetStream(ChannelHandlerContext ctx, Http2Stream stream, long errorCode, ChannelPromise promise) Http2LifecycleManager.resetStream(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise) Ensure the stream identified bystreamIdis reset.private ChannelFutureHttp2ConnectionHandler.resetUnknownStream(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise) Sends aRST_STREAMframe even if we don't know about the stream.private static ChannelFutureDefaultHttp2ConnectionEncoder.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 ChannelFutureAbstractHttp2StreamChannel.write0(ChannelHandlerContext ctx, Object msg) protected ChannelFutureHttp2MultiplexCodec.Http2MultiplexCodecStreamChannel.write0(ChannelHandlerContext ctx, Object msg) AbstractHttp2StreamChannel.writeAndFlush(Object msg) AbstractHttp2StreamChannel.writeAndFlush(Object msg, ChannelPromise promise) private ChannelFutureDefaultHttp2FrameWriter.writeContinuationFrames(ChannelHandlerContext ctx, int streamId, ByteBuf headerBlock, Http2CodecUtil.SimpleChannelPromiseAggregator promiseAggregator) Writes as many continuation frames as needed untilpaddingandheaderBlockare 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 aDATAframe 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 internalHttp2FrameWriterwithout 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 ChannelFutureDefaultHttp2ConnectionEncoder.writeHeaders0(ChannelHandlerContext ctx, int streamId, Http2Headers headers, boolean hasPriority, int streamDependency, short weight, boolean exclusive, int padding, boolean endOfStream, ChannelPromise promise) private ChannelFutureStreamBufferingEncoder.writeHeaders0(ChannelHandlerContext ctx, int streamId, Http2Headers headers, boolean hasPriority, int streamDependency, short weight, boolean exclusive, int padding, boolean endOfStream, ChannelPromise promise) private ChannelFutureDefaultHttp2FrameWriter.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.Http2MaxRstFrameLimitEncoder.writeRstStream(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise) 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 ChannelFutureAbstractHttp2StreamChannel.Http2ChannelUnsafe.writeWindowUpdateFrame(Http2WindowUpdateFrame windowUpdateFrame) Methods in io.netty.handler.codec.http2 with parameters of type ChannelFutureModifier and TypeMethodDescriptionprivate voidHttp2ConnectionHandler.checkCloseConnection(ChannelFuture future) Closes the connection if the graceful shutdown process has completed.private voidHttp2ConnectionHandler.closeConnectionOnError(ChannelHandlerContext ctx, ChannelFuture future) voidHttp2ConnectionHandler.closeStream(Http2Stream stream, ChannelFuture future) voidHttp2LifecycleManager.closeStream(Http2Stream stream, ChannelFuture future) Closes and deactivates the givenstream.voidHttp2ConnectionHandler.closeStreamLocal(Http2Stream stream, ChannelFuture future) Closes the local side of the given stream.voidHttp2LifecycleManager.closeStreamLocal(Http2Stream stream, ChannelFuture future) Closes the local side of thestream.voidHttp2ConnectionHandler.closeStreamRemote(Http2Stream stream, ChannelFuture future) Closes the remote side of the given stream.voidHttp2LifecycleManager.closeStreamRemote(Http2Stream stream, ChannelFuture future) Closes the remote side of thestream.private voidHttp2ConnectionHandler.doCloseStream(Http2Stream stream, ChannelFuture future) private voidHttp2ConnectionHandler.doGracefulShutdown(ChannelHandlerContext ctx, ChannelFuture future, ChannelPromise promise) private voidAbstractHttp2StreamChannel.Http2ChannelUnsafe.firstWriteComplete(ChannelFuture future, ChannelPromise promise) private voidHttp2FrameCodec.handleHeaderFuture(ChannelFuture channelFuture, int streamId) private voidDefaultHttp2ConnectionEncoder.notifyLifecycleManagerOnError(ChannelFuture future, ChannelHandlerContext ctx) voidDefaultHttp2ConnectionEncoder.FlowControlledBase.operationComplete(ChannelFuture future) voidHttp2ConnectionHandler.ClosingChannelFutureListener.operationComplete(ChannelFuture sentGoAwayFuture) private static voidHttp2ConnectionHandler.processGoAwayWriteResult(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData, ChannelFuture future) private voidHttp2ConnectionHandler.processRstStreamWriteResult(ChannelHandlerContext ctx, Http2Stream stream, ChannelFuture future) (package private) static voidHttp2MultiplexHandler.registerDone(ChannelFuture future) private static voidAbstractHttp2StreamChannel.windowUpdateFrameWriteComplete(ChannelFuture future, Channel streamChannel) private voidAbstractHttp2StreamChannel.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 ChannelFutureSpdySessionHandler.sendGoAwayFrame(ChannelHandlerContext ctx, SpdySessionStatus status) Methods in io.netty.handler.codec.spdy with parameters of type ChannelFutureModifier and TypeMethodDescriptionprivate voidSpdySessionHandler.halfCloseStream(int streamId, boolean remote, ChannelFuture future) voidSpdySessionHandler.ClosingChannelFutureListener.operationComplete(ChannelFuture sentGoAwayFuture) private voidSpdySessionHandler.removeStream(int streamId, ChannelFuture future) -
Uses of ChannelFuture in io.netty.handler.ipfilter
Methods in io.netty.handler.ipfilter that return ChannelFutureModifier and TypeMethodDescriptionprotected ChannelFutureAbstractRemoteAddressFilter.channelRejected(ChannelHandlerContext ctx, T remoteAddress) This method is called ifremoteAddressgets 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_notifymessage to the specified channel and destroys the underlyingSSLEngine.SslHandler.closeOutbound(ChannelPromise promise) Sends an SSLclose_notifymessage to the specified channel and destroys the underlyingSSLEngine.Methods in io.netty.handler.ssl with parameters of type ChannelFutureModifier and TypeMethodDescriptionprivate static voidSslHandler.addCloseListener(ChannelFuture future, ChannelPromise promise) private voidSslHandler.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 voidChunkedWriteHandler.handleEndOfInputFuture(ChannelFuture future, ChunkedInput<?> input, ChunkedWriteHandler.PendingWrite currentWrite) private voidChunkedWriteHandler.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 TypeMethodDescriptionvoidWriteTimeoutHandler.WriteTimeoutTask.operationComplete(ChannelFuture future) -
Uses of ChannelFuture in io.netty.resolver.dns
Fields in io.netty.resolver.dns declared as ChannelFutureModifier and TypeFieldDescriptionprivate final ChannelFutureDnsNameResolver.DnsResolveChannelPerResolverProvider.resolveChannelFutureMethods in io.netty.resolver.dns that return ChannelFutureModifier and TypeMethodDescription<T> ChannelFutureDnsNameResolver.DnsResolveChannelPerResolutionProvider.nextResolveChannel(Future<T> resolutionFuture) <T> ChannelFutureDnsNameResolver.DnsResolveChannelPerResolverProvider.nextResolveChannel(Future<T> resolutionFuture) <T> ChannelFutureDnsNameResolver.DnsResolveChannelProvider.nextResolveChannel(Future<T> resolutionFuture) Return the nextChannelFuturethat contains theChannelthat should be used for resolving a chain of queries.private static ChannelFutureDnsNameResolver.registerOrBind(Bootstrap bootstrap, SocketAddress localAddress) private ChannelFuture(package private) final ChannelFutureDnsQueryContext.writeQuery(boolean flush) Write the query and return theChannelFuturethat is completed once the write completes.Methods in io.netty.resolver.dns with parameters of type ChannelFutureModifier and TypeMethodDescriptionprivate voidDnsNameResolver.doResolveAllNow(ChannelFuture f, String hostname, DnsRecord[] additionals, Promise<List<InetAddress>> promise, DnsCache resolveCache) private voidDnsNameResolver.doResolveNow(ChannelFuture f, String hostname, DnsRecord[] additionals, Promise<InetAddress> promise, DnsCache resolveCache) private voidDnsQueryContext.onQueryWriteCompletion(long queryTimeoutMillis, ChannelFuture writeFuture) voidBiDnsQueryLifecycleObserver.queryWritten(InetSocketAddress dnsServerAddress, ChannelFuture future) voidDnsQueryLifecycleObserver.queryWritten(InetSocketAddress dnsServerAddress, ChannelFuture future) The query has been written.voidLoggingDnsQueryLifecycleObserver.queryWritten(InetSocketAddress dnsServerAddress, ChannelFuture future) voidNoopDnsQueryLifecycleObserver.queryWritten(InetSocketAddress dnsServerAddress, ChannelFuture future) private voidDnsNameResolver.resolveAllNow(ChannelFuture f, String hostname, DnsQuestion question, DnsRecord[] additionals, Promise<List<DnsRecord>> promise) private static UnknownHostExceptionDnsNameResolver.toException(ChannelFuture f, String hostname, DnsQuestion question, DnsRecord[] additionals)
EventLoopGroup.register(ChannelPromise)instead.