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.A serial and parallel port communication transport based on RXTX.
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).
UDT Transport for NIO Channels.
io_uring is a high I/O performance scalable interface for fully
asynchronous Linux syscalls.
Encoder, decoder, handshakers and their related message types for
Web Socket data frames.
Handlers for sending and receiving HTTP/2 frames.
QUIC implementation
Package to filter IP addresses (allow/deny).
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
Methods 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.AbstractBootstrap.register() -
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 TypeClassDescriptionclassThe defaultChannelProgressivePromiseimplementation.classThe defaultChannelPromiseimplementation.final classfinal classSubclasses with type arguments of type ChannelFuture in io.netty.channelModifier and TypeClassDescriptionfinal classDeprecated.final classDeprecated.usePromiseNotifier.Subinterfaces with type arguments of type ChannelFuture in io.netty.channelMethods in io.netty.channel that return ChannelFutureModifier and TypeMethodDescriptionChannelFuture.addListener(GenericFutureListener<? extends Future<? super Void>> listener) ChannelFuture.addListeners(GenericFutureListener<? extends Future<? super Void>>... listeners) ChannelFuture.await()ChannelFuture.awaitUninterruptibly()default ChannelFutureChannel.bind(SocketAddress localAddress) default ChannelFutureChannel.bind(SocketAddress localAddress, ChannelPromise promise) default ChannelFutureChannelOutboundInvoker.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.final ChannelFutureDefaultChannelPipeline.bind(SocketAddress localAddress) final ChannelFutureDefaultChannelPipeline.bind(SocketAddress localAddress, ChannelPromise promise) default ChannelFutureChannel.close()default ChannelFutureChannel.close(ChannelPromise promise) default ChannelFutureChannelOutboundInvoker.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.final ChannelFutureDefaultChannelPipeline.close()final ChannelFutureDefaultChannelPipeline.close(ChannelPromise promise) AbstractChannel.closeFuture()Channel.closeFuture()Returns theChannelFuturewhich will be notified when this channel is closed.default ChannelFutureChannel.connect(SocketAddress remoteAddress) default ChannelFutureChannel.connect(SocketAddress remoteAddress, ChannelPromise promise) default ChannelFutureChannel.connect(SocketAddress remoteAddress, SocketAddress localAddress) default ChannelFutureChannel.connect(SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) default ChannelFutureChannelOutboundInvoker.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.default ChannelFutureChannelOutboundInvoker.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.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) default ChannelFutureChannel.deregister()default ChannelFutureChannel.deregister(ChannelPromise promise) default ChannelFutureChannelOutboundInvoker.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.final ChannelFutureDefaultChannelPipeline.deregister()final ChannelFutureDefaultChannelPipeline.deregister(ChannelPromise promise) default ChannelFutureChannel.disconnect()default ChannelFutureChannel.disconnect(ChannelPromise promise) default ChannelFutureChannelOutboundInvoker.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.final ChannelFutureDefaultChannelPipeline.disconnect()final ChannelFutureDefaultChannelPipeline.disconnect(ChannelPromise promise) default ChannelFutureChannel.newFailedFuture(Throwable cause) ChannelOutboundInvoker.newFailedFuture(Throwable cause) Create a newChannelFuturewhich is marked as failed already.default ChannelFutureChannelPipeline.newFailedFuture(Throwable cause) final ChannelFutureDefaultChannelPipeline.newFailedFuture(Throwable cause) default ChannelFutureChannel.newSucceededFuture()ChannelOutboundInvoker.newSucceededFuture()Create a newChannelFuturewhich is marked as succeeded already.final ChannelFutureDefaultChannelPipeline.newSucceededFuture()EventLoopGroup.register(ChannelPromise promise) EventLoopGroup.register(Channel channel, ChannelPromise promise) Deprecated.UseEventLoopGroup.register(ChannelPromise)instead.default ChannelFutureDeprecated.default ChannelFutureIoEventLoopGroup.register(ChannelPromise promise) Deprecated.final ChannelFutureDeprecated.final ChannelFutureManualIoEventLoop.register(ChannelPromise promise) Deprecated.final ChannelFutureManualIoEventLoop.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) ChannelFuture.removeListeners(GenericFutureListener<? extends Future<? super Void>>... listeners) ChannelFuture.sync()ChannelFuture.syncUninterruptibly()default ChannelFuturedefault ChannelFutureChannel.write(Object msg, ChannelPromise promise) default ChannelFutureRequest to write a message via thisChannelHandlerContextthrough theChannelPipeline.ChannelOutboundInvoker.write(Object msg, ChannelPromise promise) Request to write a message via thisChannelHandlerContextthrough theChannelPipeline.final ChannelFuturefinal ChannelFutureDefaultChannelPipeline.write(Object msg, ChannelPromise promise) default ChannelFutureChannel.writeAndFlush(Object msg) default ChannelFutureChannel.writeAndFlush(Object msg, ChannelPromise promise) default ChannelFutureChannelOutboundInvoker.writeAndFlush(Object msg) Shortcut for callChannelOutboundInvoker.write(Object)andChannelOutboundInvoker.flush().ChannelOutboundInvoker.writeAndFlush(Object msg, ChannelPromise promise) Shortcut for callChannelOutboundInvoker.write(Object, ChannelPromise)andChannelOutboundInvoker.flush().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) -
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) 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) 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. -
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. -
Uses of ChannelFuture in io.netty.channel.group
Subinterfaces with type arguments of type ChannelFuture in io.netty.channel.groupModifier and TypeInterfaceDescriptioninterfaceThe result of an asynchronousChannelGroupoperation.Methods 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. -
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) -
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. -
Uses of ChannelFuture in io.netty.channel.rxtx
Methods in io.netty.channel.rxtx that return ChannelFutureModifier and TypeMethodDescriptionprotected ChannelFutureRxtxChannel.shutdownInput()Deprecated. -
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) -
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. -
Uses of ChannelFuture in io.netty.channel.udt.nio
Methods in io.netty.channel.udt.nio that return ChannelFutureModifier and TypeMethodDescriptionprotected ChannelFutureNioUdtByteConnectorChannel.shutdownInput()Deprecated. -
Uses of ChannelFuture in io.netty.channel.uring
Methods in io.netty.channel.uring that return ChannelFutureModifier and TypeMethodDescriptionIoUringDatagramChannel.block(InetAddress multicastAddress, InetAddress sourceToBlock) IoUringDatagramChannel.block(InetAddress multicastAddress, InetAddress sourceToBlock, ChannelPromise promise) IoUringDatagramChannel.block(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress sourceToBlock) IoUringDatagramChannel.block(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress sourceToBlock, ChannelPromise promise) IoUringDatagramChannel.joinGroup(InetAddress multicastAddress) IoUringDatagramChannel.joinGroup(InetAddress multicastAddress, ChannelPromise promise) IoUringDatagramChannel.joinGroup(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source) IoUringDatagramChannel.joinGroup(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source, ChannelPromise promise) IoUringDatagramChannel.joinGroup(InetSocketAddress multicastAddress, NetworkInterface networkInterface) IoUringDatagramChannel.joinGroup(InetSocketAddress multicastAddress, NetworkInterface networkInterface, ChannelPromise promise) IoUringDatagramChannel.leaveGroup(InetAddress multicastAddress) IoUringDatagramChannel.leaveGroup(InetAddress multicastAddress, ChannelPromise promise) IoUringDatagramChannel.leaveGroup(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source) IoUringDatagramChannel.leaveGroup(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source, ChannelPromise promise) IoUringDatagramChannel.leaveGroup(InetSocketAddress multicastAddress, NetworkInterface networkInterface) IoUringDatagramChannel.leaveGroup(InetSocketAddress multicastAddress, NetworkInterface networkInterface, ChannelPromise promise) -
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) Lz4FrameEncoder.close()Close thisLz4FrameEncoderand so finish the encoding.Lz4FrameEncoder.close(ChannelPromise promise) Close thisLz4FrameEncoderand so finish the encoding.abstract ChannelFutureZlibEncoder.close()Close thisZlibEncoderand so finish the encoding.abstract ChannelFutureZlibEncoder.close(ChannelPromise promise) Close thisZlibEncoderand so finish the encoding. -
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 frameBegins 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(Channel)}.final ChannelFutureWebSocketClientHandshaker.processHandshake(Channel channel, HttpResponse response, ChannelPromise promise) Process the opening handshake initiated byWebSocketClientHandshaker.handshake(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
Methods in io.netty.handler.codec.http2 that return ChannelFutureModifier and TypeMethodDescriptionHttp2ConnectionHandler.goAway(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData, ChannelPromise promise) 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.Http2ConnectionHandler.resetStream(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise) Http2LifecycleManager.resetStream(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise) Ensure the stream identified bystreamIdis reset.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) 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) 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) 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) 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) Methods in io.netty.handler.codec.http2 with parameters of type ChannelFutureModifier and TypeMethodDescriptionvoidHttp2ConnectionHandler.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.voidDefaultHttp2ConnectionEncoder.FlowControlledBase.operationComplete(ChannelFuture future) -
Uses of ChannelFuture in io.netty.handler.codec.quic
Methods in io.netty.handler.codec.quic that return ChannelFutureModifier and TypeMethodDescriptiondefault ChannelFutureQuicChannel.bind(SocketAddress localAddress) default ChannelFutureQuicChannel.bind(SocketAddress localAddress, ChannelPromise promise) default ChannelFutureQuicStreamChannel.bind(SocketAddress socketAddress) default ChannelFutureQuicStreamChannel.bind(SocketAddress localAddress, ChannelPromise channelPromise) default ChannelFutureQuicChannel.close()default ChannelFutureClose theQuicChannelQuicChannel.close(boolean applicationClose, int error, ByteBuf reason, ChannelPromise promise) Close theQuicChanneldefault ChannelFutureQuicChannel.close(ChannelPromise promise) default ChannelFutureQuicStreamChannel.close()default ChannelFutureQuicStreamChannel.close(ChannelPromise channelPromise) default ChannelFutureQuicChannel.connect(SocketAddress remoteAddress) default ChannelFutureQuicChannel.connect(SocketAddress remoteAddress, ChannelPromise promise) default ChannelFutureQuicChannel.connect(SocketAddress remoteAddress, SocketAddress localAddress) default ChannelFutureQuicChannel.connect(SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) default ChannelFutureQuicStreamChannel.connect(SocketAddress remoteAddress) default ChannelFutureQuicStreamChannel.connect(SocketAddress remoteAddress, ChannelPromise channelPromise) default ChannelFutureQuicStreamChannel.connect(SocketAddress remoteAddress, SocketAddress localAddress) default ChannelFutureQuicStreamChannel.connect(SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise channelPromise) default ChannelFutureQuicChannel.deregister()default ChannelFutureQuicChannel.deregister(ChannelPromise promise) default ChannelFutureQuicStreamChannel.deregister()default ChannelFutureQuicStreamChannel.deregister(ChannelPromise channelPromise) default ChannelFutureQuicChannel.disconnect()default ChannelFutureQuicChannel.disconnect(ChannelPromise promise) default ChannelFutureQuicStreamChannel.disconnect()default ChannelFutureQuicStreamChannel.disconnect(ChannelPromise channelPromise) default ChannelFutureQuicChannel.newFailedFuture(Throwable cause) default ChannelFutureQuicStreamChannel.newFailedFuture(Throwable cause) default ChannelFutureQuicChannel.newSucceededFuture()default ChannelFutureQuicStreamChannel.newSucceededFuture()default ChannelFutureQuicStreamChannel.shutdown()default ChannelFutureQuicStreamChannel.shutdown(int error) Shortcut for callingQuicStreamChannel.shutdownInput(int)andQuicStreamChannel.shutdownInput(int).QuicStreamChannel.shutdown(int error, ChannelPromise promise) Shortcut for callingQuicStreamChannel.shutdownInput(int, ChannelPromise)andQuicStreamChannel.shutdownInput(int, ChannelPromise).default ChannelFutureQuicStreamChannel.shutdownInput()default ChannelFutureQuicStreamChannel.shutdownInput(int error) Shutdown the input of the stream with the given error code.QuicStreamChannel.shutdownInput(int error, ChannelPromise promise) Shutdown the input of the stream with the given error code.default ChannelFutureQuicStreamChannel.shutdownInput(ChannelPromise promise) default ChannelFutureQuicStreamChannel.shutdownOutput()default ChannelFutureQuicStreamChannel.shutdownOutput(int error) Shutdown the output of the stream with the given error code.QuicStreamChannel.shutdownOutput(int error, ChannelPromise promise) Shutdown the output of the stream with the given error code.default ChannelFutureQuicStreamChannel.updatePriority(QuicStreamPriority priority) Update the priority of the stream.QuicStreamChannel.updatePriority(QuicStreamPriority priority, ChannelPromise promise) Update the priority of the stream.default ChannelFuturedefault ChannelFutureQuicChannel.write(Object msg, ChannelPromise promise) default ChannelFuturedefault ChannelFutureQuicStreamChannel.write(Object msg, ChannelPromise channelPromise) default ChannelFutureQuicChannel.writeAndFlush(Object msg) default ChannelFutureQuicChannel.writeAndFlush(Object msg, ChannelPromise promise) default ChannelFutureQuicStreamChannel.writeAndFlush(Object msg) default ChannelFutureQuicStreamChannel.writeAndFlush(Object msg, ChannelPromise channelPromise) -
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. -
Uses of ChannelFuture in io.netty.resolver.dns
Methods in io.netty.resolver.dns with parameters of type ChannelFutureModifier and TypeMethodDescriptionvoidBiDnsQueryLifecycleObserver.queryWritten(InetSocketAddress dnsServerAddress, ChannelFuture future) voidDnsQueryLifecycleObserver.queryWritten(InetSocketAddress dnsServerAddress, ChannelFuture future) The query has been written.
PromiseCombinerClass which is used to consolidate multiple channel futures into one, by listening to the individual futures and producing an aggregated result (success/failure) when all futures have completed.