Uses of Interface
io.netty.channel.ChannelPromise
Packages that use ChannelPromise
Package
Description
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.
BSD specific transport.
A virtual transport that enables the communication between the two
parties in the same virtual machine.
NIO-based channel
API implementation - recommended for a large number of connections (>= 1000).
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).
io_uring is a high I/O performance scalable interface for fully
asynchronous Linux syscalls.
Package to dynamically replace local / remote
SocketAddress.Extensible decoder and its common implementations which deal with the
packet fragmentation and reassembly issue found in a stream-based transport
such as TCP/IP.
Encoder, decoder and their related message types for HTTP.
This package contains Cross Origin Resource Sharing (CORS) related classes.
Encoder, decoder, handshakers and their related message types for
Web Socket data frames.
Encoder, decoder, handshakers to handle
WebSocket Extensions.
Handlers for sending and receiving HTTP/2 frames.
HTTP/3 implementation.
QUIC implementation
Encoder, decoder, session handler and their related message types for the SPDY protocol.
Package to control flush behavior.
Logs the I/O events for debugging purpose.
Capture data and write into Pcap format which helps in troubleshooting.
Adds support for client connections via proxy protocols such as
SOCKS and
HTTP CONNECT tunneling
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.Implementation of a Traffic Shaping Handler and Dynamic Statistics.
-
Uses of ChannelPromise in io.netty.channel
Subinterfaces of ChannelPromise in io.netty.channelModifier and TypeInterfaceDescriptioninterfaceSpecialChannelPromisewhich will be notified once the associated bytes is transferring.Classes in io.netty.channel that implement ChannelPromiseModifier and TypeClassDescriptionclassThe defaultChannelProgressivePromiseimplementation.classThe defaultChannelPromiseimplementation.final classfinal classMethods in io.netty.channel that return ChannelPromiseModifier and TypeMethodDescriptionChannelPromise.addListener(GenericFutureListener<? extends Future<? super Void>> listener) DefaultChannelPromise.addListener(GenericFutureListener<? extends Future<? super Void>> listener) DelegatingChannelPromiseNotifier.addListener(GenericFutureListener<? extends Future<? super Void>> listener) ChannelPromise.addListeners(GenericFutureListener<? extends Future<? super Void>>... listeners) DefaultChannelPromise.addListeners(GenericFutureListener<? extends Future<? super Void>>... listeners) DelegatingChannelPromiseNotifier.addListeners(GenericFutureListener<? extends Future<? super Void>>... listeners) ChannelPromise.await()DefaultChannelPromise.await()DelegatingChannelPromiseNotifier.await()ChannelPromise.awaitUninterruptibly()DefaultChannelPromise.awaitUninterruptibly()DelegatingChannelPromiseNotifier.awaitUninterruptibly()default ChannelPromiseChannel.newPromise()ChannelOutboundInvoker.newPromise()Return a newChannelPromise.default ChannelPromiseChannelPipeline.newPromise()final ChannelPromiseDefaultChannelPipeline.newPromise()DefaultChannelPromise.promise()PendingWriteQueue.remove()Removes a pending write operation and release it's message viaReferenceCountUtil.safeRelease(Object).ChannelPromise.removeListener(GenericFutureListener<? extends Future<? super Void>> listener) DefaultChannelPromise.removeListener(GenericFutureListener<? extends Future<? super Void>> listener) DelegatingChannelPromiseNotifier.removeListener(GenericFutureListener<? extends Future<? super Void>> listener) ChannelPromise.removeListeners(GenericFutureListener<? extends Future<? super Void>>... listeners) DefaultChannelPromise.removeListeners(GenericFutureListener<? extends Future<? super Void>>... listeners) DelegatingChannelPromiseNotifier.removeListeners(GenericFutureListener<? extends Future<? super Void>>... listeners) ChannelPromise.setFailure(Throwable cause) DefaultChannelPromise.setFailure(Throwable cause) DelegatingChannelPromiseNotifier.setFailure(Throwable cause) ChannelPromise.setSuccess()ChannelPromise.setSuccess(Void result) DefaultChannelPromise.setSuccess()DefaultChannelPromise.setSuccess(Void result) DelegatingChannelPromiseNotifier.setSuccess()DelegatingChannelPromiseNotifier.setSuccess(Void result) ChannelPromise.sync()DefaultChannelPromise.sync()DelegatingChannelPromiseNotifier.sync()ChannelPromise.syncUninterruptibly()DefaultChannelPromise.syncUninterruptibly()DelegatingChannelPromiseNotifier.syncUninterruptibly()ChannelPromise.unvoid()DefaultChannelPromise.unvoid()DelegatingChannelPromiseNotifier.unvoid()VoidChannelPromise.unvoid()final ChannelPromiseAbstractChannel.AbstractUnsafe.voidPromise()final ChannelPromiseAbstractChannel.voidPromise()Channel.Unsafe.voidPromise()Return a special ChannelPromise which can be reused and passed to the operations inChannel.Unsafe.default ChannelPromiseChannel.voidPromise()ChannelOutboundInvoker.voidPromise()Return a special ChannelPromise which can be reused for different operations.final ChannelPromiseDefaultChannelPipeline.voidPromise()Methods in io.netty.channel with parameters of type ChannelPromiseModifier and TypeMethodDescriptionfinal voidAbstractCoalescingBufferQueue.add(ByteBuf buf, ChannelPromise promise) Add a buffer to the end of the queue and associate a promise with it that should be completed when all the buffer's bytes have been consumed from the queue and written.ChannelFlushPromiseNotifier.add(ChannelPromise promise, int pendingDataSize) Deprecated.ChannelFlushPromiseNotifier.add(ChannelPromise promise, long pendingDataSize) Add aChannelPromiseto thisChannelFlushPromiseNotifierwhich will be notified after the givenpendingDataSizewas reached.voidPendingWriteQueue.add(Object msg, ChannelPromise promise) Add the givenmsgandChannelPromise.final voidAbstractCoalescingBufferQueue.addFirst(ByteBuf buf, ChannelPromise promise) Add a buffer to the front of the queue and associate a promise with it that should be completed when all the buffer's bytes have been consumed from the queue and written.voidChannelOutboundBuffer.addMessage(Object msg, int size, ChannelPromise promise) Add given message to thisChannelOutboundBuffer.final voidAbstractChannel.AbstractUnsafe.bind(SocketAddress localAddress, ChannelPromise promise) default ChannelFutureChannel.bind(SocketAddress localAddress, ChannelPromise promise) voidChannel.Unsafe.bind(SocketAddress localAddress, ChannelPromise promise) voidChannelDuplexHandler.bind(ChannelHandlerContext ctx, SocketAddress localAddress, ChannelPromise promise) CallsChannelOutboundInvoker.bind(SocketAddress, ChannelPromise)to forward to the nextChannelOutboundHandlerin theChannelPipeline.voidChannelOutboundHandler.bind(ChannelHandlerContext ctx, SocketAddress localAddress, ChannelPromise promise) Called once a bind operation is made.voidChannelOutboundHandlerAdapter.bind(ChannelHandlerContext ctx, SocketAddress localAddress, ChannelPromise promise) CallsChannelOutboundInvoker.bind(SocketAddress, ChannelPromise)to forward to the nextChannelOutboundHandlerin theChannelPipeline.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.voidCombinedChannelDuplexHandler.bind(ChannelHandlerContext ctx, SocketAddress localAddress, ChannelPromise promise) final ChannelFutureDefaultChannelPipeline.bind(SocketAddress localAddress, ChannelPromise promise) voidAbstractChannel.AbstractUnsafe.close(ChannelPromise promise) protected voidAbstractChannel.AbstractUnsafe.close(ChannelPromise promise, Throwable cause, ClosedChannelException closeCause) default ChannelFutureChannel.close(ChannelPromise promise) voidChannel.Unsafe.close(ChannelPromise promise) Close theChannelof theChannelPromiseand notify theChannelPromiseonce the operation was complete.voidChannelDuplexHandler.close(ChannelHandlerContext ctx, ChannelPromise promise) CallsChannelOutboundInvoker.close(ChannelPromise)to forward to the nextChannelOutboundHandlerin theChannelPipeline.voidChannelOutboundHandler.close(ChannelHandlerContext ctx, ChannelPromise promise) Called once a close operation is made.voidChannelOutboundHandlerAdapter.close(ChannelHandlerContext ctx, ChannelPromise promise) CallsChannelOutboundInvoker.close(ChannelPromise)to forward to the nextChannelOutboundHandlerin theChannelPipeline.ChannelOutboundInvoker.close(ChannelPromise promise) Request to close theChanneland notify theChannelFutureonce the operation completes, either because the operation was successful or because of an error.voidCombinedChannelDuplexHandler.close(ChannelHandlerContext ctx, ChannelPromise promise) final ChannelFutureDefaultChannelPipeline.close(ChannelPromise promise) default ChannelFutureChannel.connect(SocketAddress remoteAddress, ChannelPromise promise) default ChannelFutureChannel.connect(SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) voidChannel.Unsafe.connect(SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) voidChannelDuplexHandler.connect(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) CallsChannelOutboundInvoker.connect(SocketAddress, SocketAddress, ChannelPromise)to forward to the nextChannelOutboundHandlerin theChannelPipeline.voidChannelOutboundHandler.connect(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) Called once a connect operation is made.voidChannelOutboundHandlerAdapter.connect(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) CallsChannelOutboundInvoker.connect(SocketAddress, SocketAddress, ChannelPromise)to forward to the nextChannelOutboundHandlerin theChannelPipeline.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, 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.voidCombinedChannelDuplexHandler.connect(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) final ChannelFutureDefaultChannelPipeline.connect(SocketAddress remoteAddress, ChannelPromise promise) final ChannelFutureDefaultChannelPipeline.connect(SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) final voidAbstractChannel.AbstractUnsafe.deregister(ChannelPromise promise) default ChannelFutureChannel.deregister(ChannelPromise promise) voidChannel.Unsafe.deregister(ChannelPromise promise) Deregister theChannelof theChannelPromisefromEventLoopand notify theChannelPromiseonce the operation was complete.voidChannelDuplexHandler.deregister(ChannelHandlerContext ctx, ChannelPromise promise) CallsChannelOutboundInvoker.deregister(ChannelPromise)to forward to the nextChannelOutboundHandlerin theChannelPipeline.voidChannelOutboundHandler.deregister(ChannelHandlerContext ctx, ChannelPromise promise) Called once a deregister operation is made from the current registeredEventLoop.voidChannelOutboundHandlerAdapter.deregister(ChannelHandlerContext ctx, ChannelPromise promise) CallsChannelOutboundInvoker.deregister(ChannelPromise)to forward to the nextChannelOutboundHandlerin theChannelPipeline.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.voidCombinedChannelDuplexHandler.deregister(ChannelHandlerContext ctx, ChannelPromise promise) final ChannelFutureDefaultChannelPipeline.deregister(ChannelPromise promise) final voidAbstractChannel.AbstractUnsafe.disconnect(ChannelPromise promise) default ChannelFutureChannel.disconnect(ChannelPromise promise) voidChannel.Unsafe.disconnect(ChannelPromise promise) Disconnect theChannelof theChannelFutureand notify theChannelPromiseonce the operation was complete.voidChannelDuplexHandler.disconnect(ChannelHandlerContext ctx, ChannelPromise promise) CallsChannelOutboundInvoker.disconnect(ChannelPromise)to forward to the nextChannelOutboundHandlerin theChannelPipeline.voidChannelOutboundHandler.disconnect(ChannelHandlerContext ctx, ChannelPromise promise) Called once a disconnect operation is made.voidChannelOutboundHandlerAdapter.disconnect(ChannelHandlerContext ctx, ChannelPromise promise) CallsChannelOutboundInvoker.disconnect(ChannelPromise)to forward to the nextChannelOutboundHandlerin theChannelPipeline.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.voidCombinedChannelDuplexHandler.disconnect(ChannelHandlerContext ctx, ChannelPromise promise) final ChannelFutureDefaultChannelPipeline.disconnect(ChannelPromise promise) protected voidAbstractChannel.doRegister(ChannelPromise promise) protected final booleanAbstractChannel.AbstractUnsafe.ensureOpen(ChannelPromise promise) final voidAbstractChannel.AbstractUnsafe.register(EventLoop eventLoop, ChannelPromise promise) voidChannel.Unsafe.register(EventLoop eventLoop, ChannelPromise promise) Register theChannelof theChannelPromiseand notify theChannelFutureonce the registration was complete.EventLoopGroup.register(ChannelPromise promise) EventLoopGroup.register(Channel channel, ChannelPromise promise) Deprecated.UseEventLoopGroup.register(ChannelPromise)instead.default ChannelFutureIoEventLoopGroup.register(ChannelPromise promise) Deprecated.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.ThreadPerChannelEventLoopGroup.register(ChannelPromise promise) Deprecated.ThreadPerChannelEventLoopGroup.register(Channel channel, ChannelPromise promise) Deprecated.final ByteBufAbstractCoalescingBufferQueue.remove(ByteBufAllocator alloc, int bytes, ChannelPromise aggregatePromise) Remove aByteBuffrom the queue with the specified number of bytes.CoalescingBufferQueue.remove(int bytes, ChannelPromise aggregatePromise) Remove aByteBuffrom the queue with the specified number of bytes.final ByteBufAbstractCoalescingBufferQueue.removeFirst(ChannelPromise aggregatePromise) Remove the firstByteBuffrom the queue.protected final voidAbstractChannel.AbstractUnsafe.safeSetFailure(ChannelPromise promise, Throwable cause) Marks the specifiedpromiseas failure.protected final voidAbstractChannel.AbstractUnsafe.safeSetSuccess(ChannelPromise promise) Marks the specifiedpromiseas success.final voidAbstractChannel.AbstractUnsafe.shutdownOutput(ChannelPromise promise) Shutdown the output portion of the correspondingChannel.final voidAbstractChannel.AbstractUnsafe.write(Object msg, ChannelPromise promise) voidChannel.Unsafe.write(Object msg, ChannelPromise promise) Schedules a write operation.default ChannelFutureChannel.write(Object msg, ChannelPromise promise) voidChannelDuplexHandler.write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) CallsChannelOutboundInvoker.write(Object, ChannelPromise)to forward to the nextChannelOutboundHandlerin theChannelPipeline.voidChannelOutboundHandler.write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) Called once a write operation is made.voidChannelOutboundHandlerAdapter.write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) CallsChannelOutboundInvoker.write(Object, ChannelPromise)to forward to the nextChannelOutboundHandlerin theChannelPipeline.ChannelOutboundInvoker.write(Object msg, ChannelPromise promise) Request to write a message via thisChannelHandlerContextthrough theChannelPipeline.voidCombinedChannelDuplexHandler.write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) final ChannelFutureDefaultChannelPipeline.write(Object msg, ChannelPromise promise) default ChannelFutureChannel.writeAndFlush(Object msg, ChannelPromise promise) ChannelOutboundInvoker.writeAndFlush(Object msg, ChannelPromise promise) Shortcut for callChannelOutboundInvoker.write(Object, ChannelPromise)andChannelOutboundInvoker.flush().final ChannelFutureDefaultChannelPipeline.writeAndFlush(Object msg, ChannelPromise promise) Constructors in io.netty.channel with parameters of type ChannelPromiseModifierConstructorDescriptionChannelPromiseAggregator(ChannelPromise aggregatePromise) Deprecated.ChannelPromiseNotifier(boolean logNotifyFailure, ChannelPromise... promises) Deprecated.Create a new instanceChannelPromiseNotifier(ChannelPromise... promises) Deprecated.Create a new instanceDelegatingChannelPromiseNotifier(ChannelPromise delegate, boolean logNotifyFailure) -
Uses of ChannelPromise in io.netty.channel.embedded
Methods in io.netty.channel.embedded with parameters of type ChannelPromiseModifier and TypeMethodDescriptionEmbeddedChannel.bind(SocketAddress localAddress, ChannelPromise promise) final ChannelFutureEmbeddedChannel.close(ChannelPromise promise) EmbeddedChannel.connect(SocketAddress remoteAddress, ChannelPromise promise) EmbeddedChannel.connect(SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) EmbeddedChannel.deregister(ChannelPromise promise) final ChannelFutureEmbeddedChannel.disconnect(ChannelPromise promise) EmbeddedChannel.write(Object msg, ChannelPromise promise) EmbeddedChannel.writeAndFlush(Object msg, ChannelPromise promise) EmbeddedChannel.writeOneInbound(Object msg, ChannelPromise promise) Writes one message to the inbound 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 ChannelPromise in io.netty.channel.epoll
Methods in io.netty.channel.epoll with parameters of type ChannelPromiseModifier and TypeMethodDescriptionEpollDatagramChannel.block(InetAddress multicastAddress, InetAddress sourceToBlock, ChannelPromise promise) EpollDatagramChannel.block(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress sourceToBlock, ChannelPromise promise) EpollDatagramChannel.joinGroup(InetAddress multicastAddress, ChannelPromise promise) EpollDatagramChannel.joinGroup(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source, ChannelPromise promise) EpollDatagramChannel.joinGroup(InetSocketAddress multicastAddress, NetworkInterface networkInterface, ChannelPromise promise) EpollDatagramChannel.leaveGroup(InetAddress multicastAddress, ChannelPromise promise) EpollDatagramChannel.leaveGroup(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source, ChannelPromise promise) EpollDatagramChannel.leaveGroup(InetSocketAddress multicastAddress, NetworkInterface networkInterface, ChannelPromise promise) AbstractEpollStreamChannel.shutdown(ChannelPromise promise) AbstractEpollStreamChannel.shutdownInput(ChannelPromise promise) AbstractEpollStreamChannel.shutdownOutput(ChannelPromise promise) 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, ChannelPromise promise) Deprecated.Will be removed in the future.Constructors in io.netty.channel.epoll with parameters of type ChannelPromise -
Uses of ChannelPromise in io.netty.channel.kqueue
Methods in io.netty.channel.kqueue with parameters of type ChannelPromiseModifier and TypeMethodDescriptionKQueueDatagramChannel.block(InetAddress multicastAddress, InetAddress sourceToBlock, ChannelPromise promise) KQueueDatagramChannel.block(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress sourceToBlock, ChannelPromise promise) KQueueDatagramChannel.joinGroup(InetAddress multicastAddress, ChannelPromise promise) KQueueDatagramChannel.joinGroup(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source, ChannelPromise promise) KQueueDatagramChannel.joinGroup(InetSocketAddress multicastAddress, NetworkInterface networkInterface, ChannelPromise promise) KQueueDatagramChannel.leaveGroup(InetAddress multicastAddress, ChannelPromise promise) KQueueDatagramChannel.leaveGroup(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source, ChannelPromise promise) KQueueDatagramChannel.leaveGroup(InetSocketAddress multicastAddress, NetworkInterface networkInterface, ChannelPromise promise) AbstractKQueueStreamChannel.shutdown(ChannelPromise promise) AbstractKQueueStreamChannel.shutdownInput(ChannelPromise promise) AbstractKQueueStreamChannel.shutdownOutput(ChannelPromise promise) -
Uses of ChannelPromise in io.netty.channel.local
Methods in io.netty.channel.local with parameters of type ChannelPromiseModifier and TypeMethodDescriptionprotected voidLocalChannel.doRegister(ChannelPromise promise) protected voidLocalServerChannel.doRegister(ChannelPromise promise) -
Uses of ChannelPromise in io.netty.channel.nio
Methods in io.netty.channel.nio with parameters of type ChannelPromiseModifier and TypeMethodDescriptionfinal voidAbstractNioChannel.AbstractNioUnsafe.connect(SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) protected voidAbstractNioChannel.doRegister(ChannelPromise promise) -
Uses of ChannelPromise in io.netty.channel.sctp
Methods in io.netty.channel.sctp with parameters of type ChannelPromiseModifier and TypeMethodDescriptionSctpChannel.bindAddress(InetAddress localAddress, ChannelPromise promise) 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, ChannelPromise promise) 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 ChannelPromise in io.netty.channel.sctp.nio
Methods in io.netty.channel.sctp.nio with parameters of type ChannelPromiseModifier and TypeMethodDescriptionNioSctpChannel.bindAddress(InetAddress localAddress, ChannelPromise promise) NioSctpServerChannel.bindAddress(InetAddress localAddress, ChannelPromise promise) NioSctpChannel.unbindAddress(InetAddress localAddress, ChannelPromise promise) NioSctpServerChannel.unbindAddress(InetAddress localAddress, ChannelPromise promise) -
Uses of ChannelPromise in io.netty.channel.sctp.oio
Methods in io.netty.channel.sctp.oio with parameters of type ChannelPromiseModifier and TypeMethodDescriptionOioSctpChannel.bindAddress(InetAddress localAddress, ChannelPromise promise) Deprecated.OioSctpServerChannel.bindAddress(InetAddress localAddress, ChannelPromise promise) Deprecated.OioSctpChannel.unbindAddress(InetAddress localAddress, ChannelPromise promise) Deprecated.OioSctpServerChannel.unbindAddress(InetAddress localAddress, ChannelPromise promise) Deprecated. -
Uses of ChannelPromise in io.netty.channel.socket
Methods in io.netty.channel.socket with parameters of type ChannelPromiseModifier and TypeMethodDescriptionDatagramChannel.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, 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, ChannelPromise future) Joins a multicast group 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, ChannelPromise future) Joins the specified multicast group at the specified interface 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, 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, ChannelPromise future) Leaves a multicast group on a specified local interface and notifies theChannelFutureonce the operation completes.DuplexChannel.shutdown(ChannelPromise promise) Will shutdown the input and output sides of this channel.DuplexChannel.shutdownInput(ChannelPromise promise) Will shutdown the input and notifyChannelPromise.DuplexChannel.shutdownOutput(ChannelPromise promise) Will shutdown the output and notifyChannelPromise. -
Uses of ChannelPromise in io.netty.channel.socket.nio
Methods in io.netty.channel.socket.nio with parameters of type ChannelPromiseModifier and TypeMethodDescriptionNioDatagramChannel.block(InetAddress multicastAddress, InetAddress sourceToBlock, ChannelPromise promise) Block the given sourceToBlock address for the given multicastAddressNioDatagramChannel.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, ChannelPromise promise) NioDatagramChannel.joinGroup(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source, ChannelPromise promise) NioDatagramChannel.joinGroup(InetSocketAddress multicastAddress, NetworkInterface networkInterface, ChannelPromise promise) NioDatagramChannel.leaveGroup(InetAddress multicastAddress, ChannelPromise promise) NioDatagramChannel.leaveGroup(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source, ChannelPromise promise) NioDatagramChannel.leaveGroup(InetSocketAddress multicastAddress, NetworkInterface networkInterface, ChannelPromise promise) NioDomainSocketChannel.shutdown(ChannelPromise promise) NioSocketChannel.shutdown(ChannelPromise promise) NioDomainSocketChannel.shutdownInput(ChannelPromise promise) NioSocketChannel.shutdownInput(ChannelPromise promise) NioDomainSocketChannel.shutdownOutput(ChannelPromise promise) NioSocketChannel.shutdownOutput(ChannelPromise promise) -
Uses of ChannelPromise in io.netty.channel.socket.oio
Methods in io.netty.channel.socket.oio with parameters of type ChannelPromiseModifier and TypeMethodDescriptionOioDatagramChannel.block(InetAddress multicastAddress, InetAddress sourceToBlock, ChannelPromise promise) Deprecated.OioDatagramChannel.block(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress sourceToBlock, ChannelPromise promise) Deprecated.OioDatagramChannel.joinGroup(InetAddress multicastAddress, ChannelPromise promise) Deprecated.OioDatagramChannel.joinGroup(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source, ChannelPromise promise) Deprecated.OioDatagramChannel.joinGroup(InetSocketAddress multicastAddress, NetworkInterface networkInterface, ChannelPromise promise) Deprecated.OioDatagramChannel.leaveGroup(InetAddress multicastAddress, ChannelPromise promise) Deprecated.OioDatagramChannel.leaveGroup(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source, ChannelPromise promise) Deprecated.OioDatagramChannel.leaveGroup(InetSocketAddress multicastAddress, NetworkInterface networkInterface, ChannelPromise promise) Deprecated.OioSocketChannel.shutdown(ChannelPromise promise) Deprecated.OioSocketChannel.shutdownInput(ChannelPromise promise) Deprecated.OioSocketChannel.shutdownOutput(ChannelPromise promise) Deprecated. -
Uses of ChannelPromise in io.netty.channel.uring
Methods in io.netty.channel.uring with parameters of type ChannelPromiseModifier and TypeMethodDescriptionIoUringDatagramChannel.block(InetAddress multicastAddress, InetAddress sourceToBlock, ChannelPromise promise) IoUringDatagramChannel.block(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress sourceToBlock, ChannelPromise promise) IoUringDatagramChannel.joinGroup(InetAddress multicastAddress, ChannelPromise promise) IoUringDatagramChannel.joinGroup(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source, ChannelPromise promise) IoUringDatagramChannel.joinGroup(InetSocketAddress multicastAddress, NetworkInterface networkInterface, ChannelPromise promise) IoUringDatagramChannel.leaveGroup(InetAddress multicastAddress, ChannelPromise promise) IoUringDatagramChannel.leaveGroup(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source, ChannelPromise promise) IoUringDatagramChannel.leaveGroup(InetSocketAddress multicastAddress, NetworkInterface networkInterface, ChannelPromise promise) -
Uses of ChannelPromise in io.netty.handler.address
Methods in io.netty.handler.address with parameters of type ChannelPromiseModifier and TypeMethodDescriptionfinal voidDynamicAddressConnectHandler.connect(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) voidResolveAddressHandler.connect(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) -
Uses of ChannelPromise in io.netty.handler.codec
Methods in io.netty.handler.codec with parameters of type ChannelPromiseModifier and TypeMethodDescriptionvoidDatagramPacketEncoder.bind(ChannelHandlerContext ctx, SocketAddress localAddress, ChannelPromise promise) voidDatagramPacketEncoder.close(ChannelHandlerContext ctx, ChannelPromise promise) voidDatagramPacketEncoder.connect(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) voidDatagramPacketEncoder.deregister(ChannelHandlerContext ctx, ChannelPromise promise) voidDatagramPacketEncoder.disconnect(ChannelHandlerContext ctx, ChannelPromise promise) voidByteToMessageCodec.write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) voidMessageToByteEncoder.write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) voidMessageToMessageCodec.write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) voidMessageToMessageEncoder.write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) -
Uses of ChannelPromise in io.netty.handler.codec.compression
Methods in io.netty.handler.codec.compression with parameters of type ChannelPromiseModifier and TypeMethodDescriptionvoidBrotliEncoder.close(ChannelHandlerContext ctx, ChannelPromise promise) voidBzip2Encoder.close(ChannelHandlerContext ctx, ChannelPromise promise) Bzip2Encoder.close(ChannelPromise promise) Close thisBzip2Encoderand so finish the encoding.voidJdkZlibEncoder.close(ChannelHandlerContext ctx, ChannelPromise promise) JdkZlibEncoder.close(ChannelPromise promise) voidJZlibEncoder.close(ChannelHandlerContext ctx, ChannelPromise promise) JZlibEncoder.close(ChannelPromise promise) voidLz4FrameEncoder.close(ChannelHandlerContext ctx, ChannelPromise promise) Lz4FrameEncoder.close(ChannelPromise promise) Close thisLz4FrameEncoderand so finish the encoding.abstract ChannelFutureZlibEncoder.close(ChannelPromise promise) Close thisZlibEncoderand so finish the encoding. -
Uses of ChannelPromise in io.netty.handler.codec.http
Methods in io.netty.handler.codec.http with parameters of type ChannelPromiseModifier and TypeMethodDescriptionvoidHttpClientUpgradeHandler.bind(ChannelHandlerContext ctx, SocketAddress localAddress, ChannelPromise promise) voidHttpClientUpgradeHandler.close(ChannelHandlerContext ctx, ChannelPromise promise) voidHttpClientUpgradeHandler.connect(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) voidHttpClientUpgradeHandler.deregister(ChannelHandlerContext ctx, ChannelPromise promise) voidHttpClientUpgradeHandler.disconnect(ChannelHandlerContext ctx, ChannelPromise promise) voidHttpClientUpgradeHandler.write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) voidHttpObjectEncoder.write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) voidHttpServerKeepAliveHandler.write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) -
Uses of ChannelPromise in io.netty.handler.codec.http.cors
Methods in io.netty.handler.codec.http.cors with parameters of type ChannelPromiseModifier and TypeMethodDescriptionvoidCorsHandler.write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) -
Uses of ChannelPromise in io.netty.handler.codec.http.websocketx
Methods in io.netty.handler.codec.http.websocketx with parameters of type ChannelPromiseModifier and TypeMethodDescriptionWebSocketClientHandshaker.close(ChannelHandlerContext ctx, CloseWebSocketFrame frame, ChannelPromise promise) Performs the closing handshakeWebSocketClientHandshaker.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, ChannelPromise promise) 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 framefinal ChannelFutureWebSocketClientHandshaker.handshake(Channel channel, ChannelPromise promise) Begins the opening handshakefinal 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.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, ChannelPromise promise) Process the opening handshake initiated byWebSocketClientHandshaker.handshake(Channel)}.static ChannelFutureWebSocketServerHandshakerFactory.sendUnsupportedVersionResponse(Channel channel, ChannelPromise promise) Return that we need cannot support the web socket version -
Uses of ChannelPromise in io.netty.handler.codec.http.websocketx.extensions
Methods in io.netty.handler.codec.http.websocketx.extensions with parameters of type ChannelPromiseModifier and TypeMethodDescriptionprotected voidWebSocketServerExtensionHandler.onHttpResponseWrite(ChannelHandlerContext ctx, HttpResponse response, ChannelPromise promise) This is a method exposed to perform fail-fast checks of user-defined http types.voidWebSocketClientExtensionHandler.write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) voidWebSocketServerExtensionHandler.write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) -
Uses of ChannelPromise in io.netty.handler.codec.http2
Fields in io.netty.handler.codec.http2 declared as ChannelPromiseModifier and TypeFieldDescriptionprotected ChannelPromiseDefaultHttp2ConnectionEncoder.FlowControlledBase.promiseMethods in io.netty.handler.codec.http2 with parameters of type ChannelPromiseModifier and TypeMethodDescriptionvoidHttp2ConnectionHandler.bind(ChannelHandlerContext ctx, SocketAddress localAddress, ChannelPromise promise) voidHttp2ConnectionHandler.close(ChannelHandlerContext ctx, ChannelPromise promise) voidHttp2ConnectionHandler.connect(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) voidHttp2ConnectionHandler.deregister(ChannelHandlerContext ctx, ChannelPromise promise) voidHttp2ConnectionHandler.disconnect(ChannelHandlerContext ctx, ChannelPromise promise) Http2ConnectionHandler.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.voidHttp2ConnectionHandler.write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) voidHttp2FrameCodec.write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) Processes allHttp2Frames.voidHttpToHttp2ConnectionHandler.write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) Handles conversion ofHttpMessageandHttpContentto HTTP/2 frames.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) -
Uses of ChannelPromise in io.netty.handler.codec.http3
Methods in io.netty.handler.codec.http3 with parameters of type ChannelPromiseModifier and TypeMethodDescriptionvoidHttp3FrameToHttpObjectCodec.bind(ChannelHandlerContext ctx, SocketAddress localAddress, ChannelPromise promise) voidHttp3FrameToHttpObjectCodec.close(ChannelHandlerContext ctx, ChannelPromise promise) voidHttp3FrameToHttpObjectCodec.connect(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) voidHttp3FrameToHttpObjectCodec.deregister(ChannelHandlerContext ctx, ChannelPromise promise) voidHttp3FrameToHttpObjectCodec.disconnect(ChannelHandlerContext ctx, ChannelPromise promise) voidHttp3FrameToHttpObjectCodec.write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) Encode from anHttpObjectto anHttp3RequestStreamFrame. -
Uses of ChannelPromise in io.netty.handler.codec.quic
Methods in io.netty.handler.codec.quic that return ChannelPromiseModifier and TypeMethodDescriptiondefault ChannelPromiseQuicChannel.newPromise()default ChannelPromiseQuicStreamChannel.newPromise()default ChannelPromiseQuicChannel.voidPromise()default ChannelPromiseQuicStreamChannel.voidPromise()Methods in io.netty.handler.codec.quic with parameters of type ChannelPromiseModifier and TypeMethodDescriptiondefault ChannelFutureQuicChannel.bind(SocketAddress localAddress, ChannelPromise promise) default ChannelFutureQuicStreamChannel.bind(SocketAddress localAddress, ChannelPromise channelPromise) QuicChannel.close(boolean applicationClose, int error, ByteBuf reason, ChannelPromise promise) Close theQuicChanneldefault ChannelFutureQuicChannel.close(ChannelPromise promise) default ChannelFutureQuicStreamChannel.close(ChannelPromise channelPromise) default ChannelFutureQuicChannel.connect(SocketAddress remoteAddress, ChannelPromise promise) default ChannelFutureQuicChannel.connect(SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) default ChannelFutureQuicStreamChannel.connect(SocketAddress remoteAddress, ChannelPromise channelPromise) default ChannelFutureQuicStreamChannel.connect(SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise channelPromise) default ChannelFutureQuicChannel.deregister(ChannelPromise promise) default ChannelFutureQuicStreamChannel.deregister(ChannelPromise channelPromise) default ChannelFutureQuicChannel.disconnect(ChannelPromise promise) default ChannelFutureQuicStreamChannel.disconnect(ChannelPromise channelPromise) QuicStreamChannel.shutdown(int error, ChannelPromise promise) Shortcut for callingQuicStreamChannel.shutdownInput(int, ChannelPromise)andQuicStreamChannel.shutdownInput(int, ChannelPromise).QuicStreamChannel.shutdownInput(int error, ChannelPromise promise) Shutdown the input of the stream with the given error code.default ChannelFutureQuicStreamChannel.shutdownInput(ChannelPromise promise) QuicStreamChannel.shutdownOutput(int error, ChannelPromise promise) Shutdown the output of the stream with the given error code.QuicStreamChannel.updatePriority(QuicStreamPriority priority, ChannelPromise promise) Update the priority of the stream.default ChannelFutureQuicChannel.write(Object msg, ChannelPromise promise) default ChannelFutureQuicStreamChannel.write(Object msg, ChannelPromise channelPromise) default ChannelFutureQuicChannel.writeAndFlush(Object msg, ChannelPromise promise) default ChannelFutureQuicStreamChannel.writeAndFlush(Object msg, ChannelPromise channelPromise) -
Uses of ChannelPromise in io.netty.handler.codec.spdy
Methods in io.netty.handler.codec.spdy with parameters of type ChannelPromiseModifier and TypeMethodDescriptionvoidSpdyFrameCodec.bind(ChannelHandlerContext ctx, SocketAddress localAddress, ChannelPromise promise) voidSpdyFrameCodec.close(ChannelHandlerContext ctx, ChannelPromise promise) voidSpdySessionHandler.close(ChannelHandlerContext ctx, ChannelPromise promise) voidSpdyFrameCodec.connect(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) voidSpdyFrameCodec.deregister(ChannelHandlerContext ctx, ChannelPromise promise) voidSpdyFrameCodec.disconnect(ChannelHandlerContext ctx, ChannelPromise promise) voidSpdyFrameCodec.write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) voidSpdySessionHandler.write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) -
Uses of ChannelPromise in io.netty.handler.flush
Methods in io.netty.handler.flush with parameters of type ChannelPromiseModifier and TypeMethodDescriptionvoidFlushConsolidationHandler.close(ChannelHandlerContext ctx, ChannelPromise promise) voidFlushConsolidationHandler.disconnect(ChannelHandlerContext ctx, ChannelPromise promise) -
Uses of ChannelPromise in io.netty.handler.logging
Methods in io.netty.handler.logging with parameters of type ChannelPromiseModifier and TypeMethodDescriptionvoidLoggingHandler.bind(ChannelHandlerContext ctx, SocketAddress localAddress, ChannelPromise promise) voidLoggingHandler.close(ChannelHandlerContext ctx, ChannelPromise promise) voidLoggingHandler.connect(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) voidLoggingHandler.deregister(ChannelHandlerContext ctx, ChannelPromise promise) voidLoggingHandler.disconnect(ChannelHandlerContext ctx, ChannelPromise promise) voidLoggingHandler.write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) -
Uses of ChannelPromise in io.netty.handler.pcap
Methods in io.netty.handler.pcap with parameters of type ChannelPromiseModifier and TypeMethodDescriptionvoidPcapWriteHandler.write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) -
Uses of ChannelPromise in io.netty.handler.proxy
Methods in io.netty.handler.proxy with parameters of type ChannelPromiseModifier and TypeMethodDescriptionfinal voidProxyHandler.connect(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) final voidProxyHandler.write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) -
Uses of ChannelPromise in io.netty.handler.ssl
Methods in io.netty.handler.ssl with parameters of type ChannelPromiseModifier and TypeMethodDescriptionvoidSslClientHelloHandler.bind(ChannelHandlerContext ctx, SocketAddress localAddress, ChannelPromise promise) voidSslHandler.bind(ChannelHandlerContext ctx, SocketAddress localAddress, ChannelPromise promise) voidSslClientHelloHandler.close(ChannelHandlerContext ctx, ChannelPromise promise) voidSslHandler.close(ChannelHandlerContext ctx, ChannelPromise promise) SslHandler.close(ChannelPromise promise) Deprecated.SslHandler.closeOutbound(ChannelPromise promise) Sends an SSLclose_notifymessage to the specified channel and destroys the underlyingSSLEngine.voidSslClientHelloHandler.connect(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) voidSslHandler.connect(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) voidSslClientHelloHandler.deregister(ChannelHandlerContext ctx, ChannelPromise promise) voidSslHandler.deregister(ChannelHandlerContext ctx, ChannelPromise promise) voidSslClientHelloHandler.disconnect(ChannelHandlerContext ctx, ChannelPromise promise) voidSslHandler.disconnect(ChannelHandlerContext ctx, ChannelPromise promise) voidSslClientHelloHandler.write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) voidSslHandler.write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) -
Uses of ChannelPromise in io.netty.handler.stream
Methods in io.netty.handler.stream with parameters of type ChannelPromiseModifier and TypeMethodDescriptionvoidChunkedWriteHandler.write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) -
Uses of ChannelPromise in io.netty.handler.timeout
Methods in io.netty.handler.timeout with parameters of type ChannelPromiseModifier and TypeMethodDescriptionvoidIdleStateHandler.write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) voidWriteTimeoutHandler.write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) -
Uses of ChannelPromise in io.netty.handler.traffic
Methods in io.netty.handler.traffic with parameters of type ChannelPromiseModifier and TypeMethodDescriptionprotected voidAbstractTrafficShapingHandler.submitWrite(ChannelHandlerContext ctx, Object msg, long delay, ChannelPromise promise) Deprecated.protected voidGlobalChannelTrafficShapingHandler.submitWrite(ChannelHandlerContext ctx, Object msg, long size, long writedelay, long now, ChannelPromise promise) voidAbstractTrafficShapingHandler.write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) voidGlobalChannelTrafficShapingHandler.write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise)
ChannelFlushPromiseNotifier.add(ChannelPromise, long)