Uses of Interface
io.netty.channel.ChannelPromise
-
Packages that use ChannelPromise Package Description io.netty.bootstrap The helper classes with fluent API which enable an easy implementation of typical client side and server side channel initialization.io.netty.channel The core channel API which is asynchronous and event-driven abstraction of various transports such as a NIO Channel.io.netty.channel.embedded A virtualChannelthat helps wrapping a series of handlers to unit test the handlers or use them in non-I/O context.io.netty.channel.local A virtual transport that enables the communication between the two parties in the same virtual machine.io.netty.channel.nio NIO-based channel API implementation - recommended for a large number of connections (>= 1000).io.netty.channel.oio Old blocking I/O based channel API implementation - recommended for a small number of connections (< 1000).io.netty.channel.socket Abstract TCP and UDP socket interfaces which extend the core channel API.io.netty.channel.socket.nio NIO-based socket channel API implementation - recommended for a large number of connections (>= 1000).io.netty.channel.socket.oio Old blocking I/O based socket channel API implementation - recommended for a small number of connections (< 1000).io.netty.handler.address Package to dynamically replace local / remoteSocketAddress.io.netty.handler.codec 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.io.netty.handler.codec.compression io.netty.handler.codec.http Encoder, decoder and their related message types for HTTP.io.netty.handler.codec.http.cors This package contains Cross Origin Resource Sharing (CORS) related classes.io.netty.handler.codec.http.websocketx Encoder, decoder, handshakers and their related message types for Web Socket data frames.io.netty.handler.codec.http.websocketx.extensions Encoder, decoder, handshakers to handle WebSocket Extensions.io.netty.handler.codec.http2 Handlers for sending and receiving HTTP/2 frames.io.netty.handler.codec.spdy Encoder, decoder, session handler and their related message types for the SPDY protocol.io.netty.handler.flush Package to control flush behavior.io.netty.handler.logging Logs the I/O events for debugging purpose.io.netty.handler.proxy Adds support for client connections via proxy protocols such as SOCKS and HTTP CONNECT tunnelingio.netty.handler.ssl SSL · TLS implementation based onSSLEngineio.netty.handler.stream Writes very large data stream asynchronously neither spending a lot of memory nor gettingOutOfMemoryError.io.netty.handler.timeout Adds support for read and write timeout and idle connection notification using aTimer.io.netty.handler.traffic Implementation of a Traffic Shaping Handler and Dynamic Statistics.io.netty.resolver.dns An alternative to Java's built-in domain name lookup mechanism that resolves a domain name asynchronously, which supports the queries of an arbitrary DNS record type as well. -
-
Uses of ChannelPromise in io.netty.bootstrap
Classes in io.netty.bootstrap that implement ChannelPromise Modifier and Type Class Description (package private) static classAbstractBootstrap.PendingRegistrationPromiseMethods in io.netty.bootstrap with parameters of type ChannelPromise Modifier and Type Method Description voidFailedChannel.FailedChannelUnsafe. connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)private static voidAbstractBootstrap. doBind0(ChannelFuture regFuture, Channel channel, java.net.SocketAddress localAddress, ChannelPromise promise)private static voidBootstrap. doConnect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise connectPromise)private ChannelFutureBootstrap. doResolveAndConnect0(Channel channel, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise) -
Uses of ChannelPromise in io.netty.channel
Subinterfaces of ChannelPromise in io.netty.channel Modifier and Type Interface Description interfaceChannelProgressivePromiseSpecialChannelPromisewhich will be notified once the associated bytes is transferring.Classes in io.netty.channel that implement ChannelPromise Modifier and Type Class Description (package private) static classAbstractChannel.CloseFutureclassDefaultChannelProgressivePromiseThe defaultChannelProgressivePromiseimplementation.classDefaultChannelPromiseThe defaultChannelPromiseimplementation.classDelegatingChannelPromiseNotifierclassVoidChannelPromiseFields in io.netty.channel declared as ChannelPromise Modifier and Type Field Description private ChannelPromiseDelegatingChannelPromiseNotifier. delegateprivate ChannelPromiseChannelFlushPromiseNotifier.DefaultFlushCheckpoint. futureprivate ChannelPromiseAbstractChannelHandlerContext.WriteTask. promise(package private) ChannelPromiseChannelOutboundBuffer.Entry. promiseprivate ChannelPromisePendingWriteQueue.PendingWrite. promiseMethods in io.netty.channel that return ChannelPromise Modifier and Type Method Description ChannelPromiseChannelPromise. addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)ChannelPromiseDefaultChannelPromise. addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)ChannelPromiseDelegatingChannelPromiseNotifier. addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)ChannelPromiseChannelPromise. addListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners)ChannelPromiseDefaultChannelPromise. addListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners)ChannelPromiseDelegatingChannelPromiseNotifier. addListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners)ChannelPromiseChannelPromise. await()ChannelPromiseDefaultChannelPromise. await()ChannelPromiseDelegatingChannelPromiseNotifier. await()ChannelPromiseChannelPromise. awaitUninterruptibly()ChannelPromiseDefaultChannelPromise. awaitUninterruptibly()ChannelPromiseDelegatingChannelPromiseNotifier. awaitUninterruptibly()ChannelPromiseAbstractChannel. newPromise()ChannelPromiseAbstractChannelHandlerContext. newPromise()ChannelPromiseChannelOutboundInvoker. newPromise()Return a newChannelPromise.ChannelPromiseCombinedChannelDuplexHandler.DelegatingChannelHandlerContext. newPromise()ChannelPromiseDefaultChannelPipeline. newPromise()ChannelPromiseChannelFlushPromiseNotifier.DefaultFlushCheckpoint. promise()ChannelPromiseChannelFlushPromiseNotifier.FlushCheckpoint. promise()ChannelPromiseDefaultChannelPromise. promise()ChannelPromisePendingWriteQueue. remove()Removes a pending write operation and release it's message viaReferenceCountUtil.safeRelease(Object).ChannelPromiseChannelPromise. removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)ChannelPromiseDefaultChannelPromise. removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)ChannelPromiseDelegatingChannelPromiseNotifier. removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener)ChannelPromiseChannelPromise. removeListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners)ChannelPromiseDefaultChannelPromise. removeListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners)ChannelPromiseDelegatingChannelPromiseNotifier. removeListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners)ChannelPromiseAbstractChannel.CloseFuture. setFailure(java.lang.Throwable cause)ChannelPromiseChannelPromise. setFailure(java.lang.Throwable cause)ChannelPromiseDefaultChannelPromise. setFailure(java.lang.Throwable cause)ChannelPromiseDelegatingChannelPromiseNotifier. setFailure(java.lang.Throwable cause)ChannelPromiseAbstractChannel.CloseFuture. setSuccess()ChannelPromiseChannelPromise. setSuccess()ChannelPromiseChannelPromise. setSuccess(java.lang.Void result)ChannelPromiseDefaultChannelPromise. setSuccess()ChannelPromiseDefaultChannelPromise. setSuccess(java.lang.Void result)ChannelPromiseDelegatingChannelPromiseNotifier. setSuccess()ChannelPromiseDelegatingChannelPromiseNotifier. setSuccess(java.lang.Void result)ChannelPromiseChannelPromise. sync()ChannelPromiseDefaultChannelPromise. sync()ChannelPromiseDelegatingChannelPromiseNotifier. sync()ChannelPromiseChannelPromise. syncUninterruptibly()ChannelPromiseDefaultChannelPromise. syncUninterruptibly()ChannelPromiseDelegatingChannelPromiseNotifier. syncUninterruptibly()ChannelPromiseChannelPromise. unvoid()ChannelPromiseDefaultChannelPromise. unvoid()ChannelPromiseDelegatingChannelPromiseNotifier. unvoid()ChannelPromiseVoidChannelPromise. unvoid()ChannelPromiseAbstractChannel.AbstractUnsafe. voidPromise()ChannelPromiseAbstractChannel. voidPromise()ChannelPromiseAbstractChannelHandlerContext. voidPromise()ChannelPromiseChannel.Unsafe. voidPromise()Return a special ChannelPromise which can be reused and passed to the operations inChannel.Unsafe.ChannelPromiseChannelOutboundInvoker. voidPromise()Return a special ChannelPromise which can be reused for different operations.ChannelPromiseCombinedChannelDuplexHandler.DelegatingChannelHandlerContext. voidPromise()ChannelPromiseDefaultChannelPipeline. voidPromise()Methods in io.netty.channel with parameters of type ChannelPromise Modifier and Type Method Description 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.ChannelFlushPromiseNotifierChannelFlushPromiseNotifier. add(ChannelPromise promise, int pendingDataSize)Deprecated.ChannelFlushPromiseNotifierChannelFlushPromiseNotifier. add(ChannelPromise promise, long pendingDataSize)Add aChannelPromiseto thisChannelFlushPromiseNotifierwhich will be notified after the givenpendingDataSizewas reached.voidPendingWriteQueue. add(java.lang.Object msg, ChannelPromise promise)Add the givenmsgandChannelPromise.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(java.lang.Object msg, int size, ChannelPromise promise)Add given message to thisChannelOutboundBuffer.voidAbstractChannel.AbstractUnsafe. bind(java.net.SocketAddress localAddress, ChannelPromise promise)ChannelFutureAbstractChannel. bind(java.net.SocketAddress localAddress, ChannelPromise promise)ChannelFutureAbstractChannelHandlerContext. bind(java.net.SocketAddress localAddress, ChannelPromise promise)voidChannel.Unsafe. bind(java.net.SocketAddress localAddress, ChannelPromise promise)voidChannelDuplexHandler. bind(ChannelHandlerContext ctx, java.net.SocketAddress localAddress, ChannelPromise promise)CallsChannelOutboundInvoker.bind(SocketAddress, ChannelPromise)to forward to the nextChannelOutboundHandlerin theChannelPipeline.voidChannelOutboundHandler. bind(ChannelHandlerContext ctx, java.net.SocketAddress localAddress, ChannelPromise promise)Called once a bind operation is made.voidChannelOutboundHandlerAdapter. bind(ChannelHandlerContext ctx, java.net.SocketAddress localAddress, ChannelPromise promise)CallsChannelOutboundInvoker.bind(SocketAddress, ChannelPromise)to forward to the nextChannelOutboundHandlerin theChannelPipeline.ChannelFutureChannelOutboundInvoker. bind(java.net.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, java.net.SocketAddress localAddress, ChannelPromise promise)ChannelFutureCombinedChannelDuplexHandler.DelegatingChannelHandlerContext. bind(java.net.SocketAddress localAddress, ChannelPromise promise)ChannelFutureDefaultChannelPipeline. bind(java.net.SocketAddress localAddress, ChannelPromise promise)voidDefaultChannelPipeline.HeadContext. bind(ChannelHandlerContext ctx, java.net.SocketAddress localAddress, ChannelPromise promise)voidAbstractChannel.AbstractUnsafe. close(ChannelPromise promise)private voidAbstractChannel.AbstractUnsafe. close(ChannelPromise promise, java.lang.Throwable cause, java.nio.channels.ClosedChannelException closeCause, boolean notify)ChannelFutureAbstractChannel. close(ChannelPromise promise)ChannelFutureAbstractChannelHandlerContext. 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.ChannelFutureChannelOutboundInvoker. 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)ChannelFutureCombinedChannelDuplexHandler.DelegatingChannelHandlerContext. close(ChannelPromise promise)ChannelFutureDefaultChannelPipeline. close(ChannelPromise promise)voidDefaultChannelPipeline.HeadContext. close(ChannelHandlerContext ctx, ChannelPromise promise)ChannelFutureAbstractChannel. connect(java.net.SocketAddress remoteAddress, ChannelPromise promise)ChannelFutureAbstractChannel. connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)ChannelFutureAbstractChannelHandlerContext. connect(java.net.SocketAddress remoteAddress, ChannelPromise promise)ChannelFutureAbstractChannelHandlerContext. connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)voidAbstractServerChannel.DefaultServerUnsafe. connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)voidChannel.Unsafe. connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)voidChannelDuplexHandler. connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)CallsChannelOutboundInvoker.connect(SocketAddress, SocketAddress, ChannelPromise)to forward to the nextChannelOutboundHandlerin theChannelPipeline.voidChannelOutboundHandler. connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)Called once a connect operation is made.voidChannelOutboundHandlerAdapter. connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)CallsChannelOutboundInvoker.connect(SocketAddress, SocketAddress, ChannelPromise)to forward to the nextChannelOutboundHandlerin theChannelPipeline.ChannelFutureChannelOutboundInvoker. connect(java.net.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.ChannelFutureChannelOutboundInvoker. connect(java.net.SocketAddress remoteAddress, java.net.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, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)ChannelFutureCombinedChannelDuplexHandler.DelegatingChannelHandlerContext. connect(java.net.SocketAddress remoteAddress, ChannelPromise promise)ChannelFutureCombinedChannelDuplexHandler.DelegatingChannelHandlerContext. connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)ChannelFutureDefaultChannelPipeline. connect(java.net.SocketAddress remoteAddress, ChannelPromise promise)ChannelFutureDefaultChannelPipeline. connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)voidDefaultChannelPipeline.HeadContext. connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)voidAbstractChannel.AbstractUnsafe. deregister(ChannelPromise promise)private voidAbstractChannel.AbstractUnsafe. deregister(ChannelPromise promise, boolean fireChannelInactive)ChannelFutureAbstractChannel. deregister(ChannelPromise promise)ChannelFutureAbstractChannelHandlerContext. 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.ChannelFutureChannelOutboundInvoker. 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.ChannelFutureCombinedChannelDuplexHandler.DelegatingChannelHandlerContext. deregister(ChannelPromise promise)voidCombinedChannelDuplexHandler. deregister(ChannelHandlerContext ctx, ChannelPromise promise)ChannelFutureDefaultChannelPipeline. deregister(ChannelPromise promise)voidDefaultChannelPipeline.HeadContext. deregister(ChannelHandlerContext ctx, ChannelPromise promise)voidAbstractChannel.AbstractUnsafe. disconnect(ChannelPromise promise)ChannelFutureAbstractChannel. disconnect(ChannelPromise promise)ChannelFutureAbstractChannelHandlerContext. 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.ChannelFutureChannelOutboundInvoker. 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.ChannelFutureCombinedChannelDuplexHandler.DelegatingChannelHandlerContext. disconnect(ChannelPromise promise)voidCombinedChannelDuplexHandler. disconnect(ChannelHandlerContext ctx, ChannelPromise promise)ChannelFutureDefaultChannelPipeline. disconnect(ChannelPromise promise)voidDefaultChannelPipeline.HeadContext. disconnect(ChannelHandlerContext ctx, ChannelPromise promise)private voidAbstractChannel.AbstractUnsafe. doClose0(ChannelPromise promise)protected booleanAbstractChannel.AbstractUnsafe. ensureOpen(ChannelPromise promise)protected static voidAbstractChannelHandlerContext.WriteTask. init(AbstractChannelHandlerContext.WriteTask task, AbstractChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise, boolean flush)private voidAbstractChannelHandlerContext. invokeBind(java.net.SocketAddress localAddress, ChannelPromise promise)private voidAbstractChannelHandlerContext. invokeClose(ChannelPromise promise)private voidAbstractChannelHandlerContext. invokeConnect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)private voidAbstractChannelHandlerContext. invokeDeregister(ChannelPromise promise)private voidAbstractChannelHandlerContext. invokeDisconnect(ChannelPromise promise)(package private) voidAbstractChannelHandlerContext. invokeWrite(java.lang.Object msg, ChannelPromise promise)private voidAbstractChannelHandlerContext. invokeWrite0(java.lang.Object msg, ChannelPromise promise)(package private) voidAbstractChannelHandlerContext. invokeWriteAndFlush(java.lang.Object msg, ChannelPromise promise)private booleanAbstractChannelHandlerContext. isNotValidPromise(ChannelPromise promise, boolean allowVoidPromise)(package private) static AbstractChannelHandlerContext.WriteTaskAbstractChannelHandlerContext.WriteTask. newInstance(AbstractChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise, boolean flush)(package private) static ChannelOutboundBuffer.EntryChannelOutboundBuffer.Entry. newInstance(java.lang.Object msg, int size, long total, ChannelPromise promise)(package private) static PendingWriteQueue.PendingWritePendingWriteQueue.PendingWrite. newInstance(java.lang.Object msg, int size, ChannelPromise promise)private static voidAbstractChannelHandlerContext. notifyOutboundHandlerException(java.lang.Throwable cause, ChannelPromise promise)voidAbstractChannel.AbstractUnsafe. register(EventLoop eventLoop, ChannelPromise promise)voidChannel.Unsafe. register(EventLoop eventLoop, ChannelPromise promise)Register theChannelof theChannelPromiseand notify theChannelFutureonce the registration was complete.ChannelFutureEventLoopGroup. register(ChannelPromise promise)ChannelFutureEventLoopGroup. register(Channel channel, ChannelPromise promise)Deprecated.UseEventLoopGroup.register(ChannelPromise)instead.ChannelFutureMultithreadEventLoopGroup. register(ChannelPromise promise)ChannelFutureMultithreadEventLoopGroup. register(Channel channel, ChannelPromise promise)Deprecated.ChannelFutureSingleThreadEventLoop. register(ChannelPromise promise)ChannelFutureSingleThreadEventLoop. register(Channel channel, ChannelPromise promise)Deprecated.ChannelFutureThreadPerChannelEventLoop. register(ChannelPromise promise)Deprecated.ChannelFutureThreadPerChannelEventLoop. register(Channel channel, ChannelPromise promise)Deprecated.ChannelFutureThreadPerChannelEventLoopGroup. register(ChannelPromise promise)Deprecated.ChannelFutureThreadPerChannelEventLoopGroup. register(Channel channel, ChannelPromise promise)Deprecated.private voidAbstractChannel.AbstractUnsafe. register0(ChannelPromise promise)ByteBufAbstractCoalescingBufferQueue. remove(ByteBufAllocator alloc, int bytes, ChannelPromise aggregatePromise)Remove aByteBuffrom the queue with the specified number of bytes.ByteBufCoalescingBufferQueue. remove(int bytes, ChannelPromise aggregatePromise)Remove aByteBuffrom the queue with the specified number of bytes.ByteBufAbstractCoalescingBufferQueue. removeFirst(ChannelPromise aggregatePromise)Remove the firstByteBuffrom the queue.private static booleanAbstractChannelHandlerContext. safeExecute(EventExecutor executor, java.lang.Runnable runnable, ChannelPromise promise, java.lang.Object msg, boolean lazy)private static voidChannelOutboundBuffer. safeFail(ChannelPromise promise, java.lang.Throwable cause)private static voidPendingWriteQueue. safeFail(ChannelPromise promise, java.lang.Throwable cause)protected voidAbstractChannel.AbstractUnsafe. safeSetFailure(ChannelPromise promise, java.lang.Throwable cause)Marks the specifiedpromiseas failure.protected voidAbstractChannel.AbstractUnsafe. safeSetSuccess(ChannelPromise promise)Marks the specifiedpromiseas success.private static voidChannelOutboundBuffer. safeSuccess(ChannelPromise promise)voidAbstractChannel.AbstractUnsafe. shutdownOutput(ChannelPromise promise)Shutdown the output portion of the correspondingChannel.private voidAbstractChannel.AbstractUnsafe. shutdownOutput(ChannelPromise promise, java.lang.Throwable cause)Shutdown the output portion of the correspondingChannel.private static ChannelFutureListenerAbstractCoalescingBufferQueue. toChannelFutureListener(ChannelPromise promise)voidAbstractChannel.AbstractUnsafe. write(java.lang.Object msg, ChannelPromise promise)ChannelFutureAbstractChannel. write(java.lang.Object msg, ChannelPromise promise)private voidAbstractChannelHandlerContext. write(java.lang.Object msg, boolean flush, ChannelPromise promise)ChannelFutureAbstractChannelHandlerContext. write(java.lang.Object msg, ChannelPromise promise)voidChannel.Unsafe. write(java.lang.Object msg, ChannelPromise promise)Schedules a write operation.voidChannelDuplexHandler. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)CallsChannelOutboundInvoker.write(Object, ChannelPromise)to forward to the nextChannelOutboundHandlerin theChannelPipeline.voidChannelOutboundHandler. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)Called once a write operation is made.voidChannelOutboundHandlerAdapter. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)CallsChannelOutboundInvoker.write(Object, ChannelPromise)to forward to the nextChannelOutboundHandlerin theChannelPipeline.ChannelFutureChannelOutboundInvoker. write(java.lang.Object msg, ChannelPromise promise)Request to write a message via thisChannelHandlerContextthrough theChannelPipeline.ChannelFutureCombinedChannelDuplexHandler.DelegatingChannelHandlerContext. write(java.lang.Object msg, ChannelPromise promise)voidCombinedChannelDuplexHandler. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)voidDefaultChannelPipeline.HeadContext. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)ChannelFutureDefaultChannelPipeline. write(java.lang.Object msg, ChannelPromise promise)ChannelFutureAbstractChannel. writeAndFlush(java.lang.Object msg, ChannelPromise promise)ChannelFutureAbstractChannelHandlerContext. writeAndFlush(java.lang.Object msg, ChannelPromise promise)ChannelFutureChannelOutboundInvoker. writeAndFlush(java.lang.Object msg, ChannelPromise promise)Shortcut for callChannelOutboundInvoker.write(Object, ChannelPromise)andChannelOutboundInvoker.flush().ChannelFutureCombinedChannelDuplexHandler.DelegatingChannelHandlerContext. writeAndFlush(java.lang.Object msg, ChannelPromise promise)ChannelFutureDefaultChannelPipeline. writeAndFlush(java.lang.Object msg, ChannelPromise promise)Constructors in io.netty.channel with parameters of type ChannelPromise Constructor Description ChannelPromiseAggregator(ChannelPromise aggregatePromise)Deprecated.ChannelPromiseNotifier(boolean logNotifyFailure, ChannelPromise... promises)Create a new instanceChannelPromiseNotifier(ChannelPromise... promises)Create a new instanceDefaultFlushCheckpoint(long checkpoint, ChannelPromise future)DelegatingChannelPromiseNotifier(ChannelPromise delegate)DelegatingChannelPromiseNotifier(ChannelPromise delegate, boolean logNotifyFailure) -
Uses of ChannelPromise in io.netty.channel.embedded
Methods in io.netty.channel.embedded with parameters of type ChannelPromise Modifier and Type Method Description private ChannelFutureEmbeddedChannel. checkException(ChannelPromise promise)Checks for the presence of anException.ChannelFutureEmbeddedChannel. close(ChannelPromise promise)voidEmbeddedChannel.EmbeddedUnsafe. connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)ChannelFutureEmbeddedChannel. disconnect(ChannelPromise promise)private ChannelFutureEmbeddedChannel. flushInbound(boolean recordException, ChannelPromise promise)ChannelFutureEmbeddedEventLoop. register(ChannelPromise promise)ChannelFutureEmbeddedEventLoop. register(Channel channel, ChannelPromise promise)Deprecated.ChannelFutureEmbeddedChannel. writeOneInbound(java.lang.Object msg, ChannelPromise promise)Writes one message to the inbound of thisChanneland does not flush it.ChannelFutureEmbeddedChannel. writeOneOutbound(java.lang.Object msg, ChannelPromise promise)Writes one message to the outbound of thisChanneland does not flush it. -
Uses of ChannelPromise in io.netty.channel.local
Fields in io.netty.channel.local declared as ChannelPromise Modifier and Type Field Description private ChannelPromiseLocalChannel. connectPromiseMethods in io.netty.channel.local with parameters of type ChannelPromise Modifier and Type Method Description voidLocalChannel.LocalUnsafe. connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise) -
Uses of ChannelPromise in io.netty.channel.nio
Fields in io.netty.channel.nio declared as ChannelPromise Modifier and Type Field Description private ChannelPromiseAbstractNioChannel. connectPromiseThe future of the current connection attempt.Methods in io.netty.channel.nio with parameters of type ChannelPromise Modifier and Type Method Description voidAbstractNioChannel.AbstractNioUnsafe. connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)private voidAbstractNioChannel.AbstractNioUnsafe. fulfillConnectPromise(ChannelPromise promise, boolean wasActive)private voidAbstractNioChannel.AbstractNioUnsafe. fulfillConnectPromise(ChannelPromise promise, java.lang.Throwable cause) -
Uses of ChannelPromise in io.netty.channel.oio
Methods in io.netty.channel.oio with parameters of type ChannelPromise Modifier and Type Method Description voidAbstractOioChannel.DefaultOioUnsafe. connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise) -
Uses of ChannelPromise in io.netty.channel.socket
Methods in io.netty.channel.socket with parameters of type ChannelPromise Modifier and Type Method Description ChannelFutureDatagramChannel. block(java.net.InetAddress multicastAddress, java.net.InetAddress sourceToBlock, ChannelPromise future)Block the given sourceToBlock address for the given multicastAddress and notifies theChannelFutureonce the operation completes.ChannelFutureDatagramChannel. block(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress sourceToBlock, ChannelPromise future)Block the given sourceToBlock address for the given multicastAddress on the given networkInterface and notifies theChannelFutureonce the operation completes.ChannelFutureDatagramChannel. joinGroup(java.net.InetAddress multicastAddress, ChannelPromise future)Joins a multicast group and notifies theChannelFutureonce the operation completes.ChannelFutureDatagramChannel. joinGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source, ChannelPromise future)Joins the specified multicast group at the specified interface and notifies theChannelFutureonce the operation completes.ChannelFutureDatagramChannel. joinGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface, ChannelPromise future)Joins the specified multicast group at the specified interface and notifies theChannelFutureonce the operation completes.ChannelFutureDatagramChannel. leaveGroup(java.net.InetAddress multicastAddress, ChannelPromise future)Leaves a multicast group and notifies theChannelFutureonce the operation completes.ChannelFutureDatagramChannel. leaveGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source, ChannelPromise future)Leave the specified multicast group at the specified interface using the specified source and notifies theChannelFutureonce the operation completes.ChannelFutureDatagramChannel. leaveGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface, ChannelPromise future)Leaves a multicast group on a specified local interface and notifies theChannelFutureonce the operation completes.ChannelFutureDuplexChannel. shutdown(ChannelPromise promise)Will shutdown the input and output sides of this channel.ChannelFutureDuplexChannel. shutdownInput(ChannelPromise promise)Will shutdown the input and notifyChannelPromise.ChannelFutureDuplexChannel. 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 ChannelPromise Modifier and Type Method Description ChannelFutureNioDatagramChannel. block(java.net.InetAddress multicastAddress, java.net.InetAddress sourceToBlock, ChannelPromise promise)Block the given sourceToBlock address for the given multicastAddressChannelFutureNioDatagramChannel. block(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress sourceToBlock, ChannelPromise promise)Block the given sourceToBlock address for the given multicastAddress on the given networkInterfaceChannelFutureNioDatagramChannel. joinGroup(java.net.InetAddress multicastAddress, ChannelPromise promise)ChannelFutureNioDatagramChannel. joinGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source, ChannelPromise promise)ChannelFutureNioDatagramChannel. joinGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface, ChannelPromise promise)ChannelFutureNioDatagramChannel. leaveGroup(java.net.InetAddress multicastAddress, ChannelPromise promise)ChannelFutureNioDatagramChannel. leaveGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source, ChannelPromise promise)ChannelFutureNioDatagramChannel. leaveGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface, ChannelPromise promise)ChannelFutureNioSocketChannel. shutdown(ChannelPromise promise)private static voidNioSocketChannel. shutdownDone(ChannelFuture shutdownOutputFuture, ChannelFuture shutdownInputFuture, ChannelPromise promise)ChannelFutureNioSocketChannel. shutdownInput(ChannelPromise promise)private voidNioSocketChannel. shutdownInput0(ChannelPromise promise)ChannelFutureNioSocketChannel. shutdownOutput(ChannelPromise promise)private voidNioSocketChannel. shutdownOutputDone(ChannelFuture shutdownOutputFuture, ChannelPromise promise) -
Uses of ChannelPromise in io.netty.channel.socket.oio
Methods in io.netty.channel.socket.oio with parameters of type ChannelPromise Modifier and Type Method Description ChannelFutureOioDatagramChannel. block(java.net.InetAddress multicastAddress, java.net.InetAddress sourceToBlock, ChannelPromise promise)Deprecated.ChannelFutureOioDatagramChannel. block(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress sourceToBlock, ChannelPromise promise)Deprecated.ChannelFutureOioDatagramChannel. joinGroup(java.net.InetAddress multicastAddress, ChannelPromise promise)Deprecated.ChannelFutureOioDatagramChannel. joinGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source, ChannelPromise promise)Deprecated.ChannelFutureOioDatagramChannel. joinGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface, ChannelPromise promise)Deprecated.ChannelFutureOioDatagramChannel. leaveGroup(java.net.InetAddress multicastAddress, ChannelPromise promise)Deprecated.ChannelFutureOioDatagramChannel. leaveGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source, ChannelPromise promise)Deprecated.ChannelFutureOioDatagramChannel. leaveGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface, ChannelPromise promise)Deprecated.ChannelFutureOioSocketChannel. shutdown(ChannelPromise promise)Deprecated.private static voidOioSocketChannel. shutdownDone(ChannelFuture shutdownOutputFuture, ChannelFuture shutdownInputFuture, ChannelPromise promise)Deprecated.ChannelFutureOioSocketChannel. shutdownInput(ChannelPromise promise)Deprecated.private voidOioSocketChannel. shutdownInput0(ChannelPromise promise)Deprecated.ChannelFutureOioSocketChannel. shutdownOutput(ChannelPromise promise)Deprecated.private voidOioSocketChannel. shutdownOutput0(ChannelPromise promise)Deprecated.private voidOioSocketChannel. shutdownOutputDone(ChannelFuture shutdownOutputFuture, ChannelPromise promise)Deprecated. -
Uses of ChannelPromise in io.netty.handler.address
Methods in io.netty.handler.address with parameters of type ChannelPromise Modifier and Type Method Description voidDynamicAddressConnectHandler. connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)voidResolveAddressHandler. connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise) -
Uses of ChannelPromise in io.netty.handler.codec
Methods in io.netty.handler.codec with parameters of type ChannelPromise Modifier and Type Method Description voidDatagramPacketEncoder. bind(ChannelHandlerContext ctx, java.net.SocketAddress localAddress, ChannelPromise promise)voidDatagramPacketEncoder. close(ChannelHandlerContext ctx, ChannelPromise promise)voidDatagramPacketEncoder. connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)voidDatagramPacketEncoder. deregister(ChannelHandlerContext ctx, ChannelPromise promise)voidDatagramPacketEncoder. disconnect(ChannelHandlerContext ctx, ChannelPromise promise)voidByteToMessageCodec. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)voidMessageToByteEncoder. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)voidMessageToMessageCodec. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)voidMessageToMessageEncoder. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)private static voidMessageToMessageEncoder. writePromiseCombiner(ChannelHandlerContext ctx, CodecOutputList out, ChannelPromise promise) -
Uses of ChannelPromise in io.netty.handler.codec.compression
Methods in io.netty.handler.codec.compression with parameters of type ChannelPromise Modifier and Type Method Description voidBzip2Encoder. close(ChannelHandlerContext ctx, ChannelPromise promise)ChannelFutureBzip2Encoder. close(ChannelPromise promise)Close thisBzip2Encoderand so finish the encoding.voidJdkZlibEncoder. close(ChannelHandlerContext ctx, ChannelPromise promise)ChannelFutureJdkZlibEncoder. close(ChannelPromise promise)voidJZlibEncoder. close(ChannelHandlerContext ctx, ChannelPromise promise)ChannelFutureJZlibEncoder. close(ChannelPromise promise)abstract ChannelFutureZlibEncoder. close(ChannelPromise promise)Close thisZlibEncoderand so finish the encoding.private ChannelFutureBzip2Encoder. finishEncode(ChannelHandlerContext ctx, ChannelPromise promise)private ChannelFutureJdkZlibEncoder. finishEncode(ChannelHandlerContext ctx, ChannelPromise promise)private ChannelFutureJZlibEncoder. finishEncode(ChannelHandlerContext ctx, ChannelPromise promise) -
Uses of ChannelPromise in io.netty.handler.codec.http
Methods in io.netty.handler.codec.http with parameters of type ChannelPromise Modifier and Type Method Description voidHttpClientUpgradeHandler. bind(ChannelHandlerContext ctx, java.net.SocketAddress localAddress, ChannelPromise promise)voidHttpClientUpgradeHandler. close(ChannelHandlerContext ctx, ChannelPromise promise)voidHttpClientUpgradeHandler. connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)voidHttpClientUpgradeHandler. deregister(ChannelHandlerContext ctx, ChannelPromise promise)voidHttpClientUpgradeHandler. disconnect(ChannelHandlerContext ctx, ChannelPromise promise)voidHttpClientUpgradeHandler. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)voidHttpServerKeepAliveHandler. write(ChannelHandlerContext ctx, java.lang.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 ChannelPromise Modifier and Type Method Description voidCorsHandler. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise) -
Uses of ChannelPromise in io.netty.handler.codec.http.websocketx
Fields in io.netty.handler.codec.http.websocketx declared as ChannelPromise Modifier and Type Field Description private ChannelPromiseWebSocketProtocolHandler. closeSentprivate ChannelPromiseWebSocketClientProtocolHandshakeHandler. handshakePromiseprivate ChannelPromiseWebSocketServerProtocolHandshakeHandler. handshakePromiseMethods in io.netty.handler.codec.http.websocketx with parameters of type ChannelPromise Modifier and Type Method Description voidWebSocketProtocolHandler. bind(ChannelHandlerContext ctx, java.net.SocketAddress localAddress, ChannelPromise promise)ChannelFutureWebSocketClientHandshaker. close(Channel channel, CloseWebSocketFrame frame, ChannelPromise promise)Performs the closing handshakevoidWebSocketProtocolHandler. close(ChannelHandlerContext ctx, ChannelPromise promise)ChannelFutureWebSocketServerHandshaker. close(Channel channel, CloseWebSocketFrame frame, ChannelPromise promise)Performs the closing handshakeChannelFutureWebSocketServerHandshaker00. close(Channel channel, CloseWebSocketFrame frame, ChannelPromise promise)Echo back the closing framevoidWebSocketProtocolHandler. connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)voidWebSocketProtocolHandler. deregister(ChannelHandlerContext ctx, ChannelPromise promise)voidWebSocketProtocolHandler. disconnect(ChannelHandlerContext ctx, ChannelPromise promise)ChannelFutureWebSocketClientHandshaker. handshake(Channel channel, ChannelPromise promise)Begins the opening handshakeChannelFutureWebSocketServerHandshaker. 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.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.ChannelFutureWebSocketClientHandshaker. processHandshake(Channel channel, HttpResponse response, ChannelPromise promise)Process the opening handshake initiated byWebSocketClientHandshaker.handshake(io.netty.channel.Channel)}.static ChannelFutureWebSocketServerHandshakerFactory. sendUnsupportedVersionResponse(Channel channel, ChannelPromise promise)Return that we need cannot not support the web socket versionvoidWebSocketProtocolHandler. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise) -
Uses of ChannelPromise in io.netty.handler.codec.http.websocketx.extensions
Methods in io.netty.handler.codec.http.websocketx.extensions with parameters of type ChannelPromise Modifier and Type Method Description voidWebSocketClientExtensionHandler. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)voidWebSocketServerExtensionHandler. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise) -
Uses of ChannelPromise in io.netty.handler.codec.http2
Classes in io.netty.handler.codec.http2 that implement ChannelPromise Modifier and Type Class Description (package private) static classHttp2CodecUtil.SimpleChannelPromiseAggregatorProvides the ability to associate the outcome of multipleChannelPromiseobjects into a singleChannelPromiseobject.Fields in io.netty.handler.codec.http2 declared as ChannelPromise Modifier and Type Field Description private ChannelPromiseAbstractHttp2StreamChannel. closePromiseprotected ChannelPromiseDefaultHttp2ConnectionEncoder.FlowControlledBase. promiseprivate ChannelPromiseHttp2CodecUtil.SimpleChannelPromiseAggregator. promiseprivate ChannelPromiseHttp2ConnectionHandler.ClosingChannelFutureListener. promise(package private) ChannelPromiseStreamBufferingEncoder.Frame. promiseMethods in io.netty.handler.codec.http2 that return ChannelPromise Modifier and Type Method Description ChannelPromiseHttp2CodecUtil.SimpleChannelPromiseAggregator. doneAllocatingPromises()Signify that no moreHttp2CodecUtil.SimpleChannelPromiseAggregator.newPromise()allocations will be made.private ChannelPromiseHttp2ControlFrameLimitEncoder. handleOutstandingControlFrames(ChannelHandlerContext ctx, ChannelPromise promise)ChannelPromiseAbstractHttp2StreamChannel. newPromise()ChannelPromiseHttp2CodecUtil.SimpleChannelPromiseAggregator. newPromise()Allocate a new promise which will be used to aggregate the overall success of this promise aggregator.ChannelPromiseHttp2CodecUtil.SimpleChannelPromiseAggregator. setFailure(java.lang.Throwable cause)Fail this object if it has not already been failed.private ChannelPromiseHttp2CodecUtil.SimpleChannelPromiseAggregator. setPromise()ChannelPromiseHttp2CodecUtil.SimpleChannelPromiseAggregator. setSuccess(java.lang.Void result)ChannelPromiseAbstractHttp2StreamChannel.Http2ChannelUnsafe. voidPromise()ChannelPromiseAbstractHttp2StreamChannel. voidPromise()Methods in io.netty.handler.codec.http2 with parameters of type ChannelPromise Modifier and Type Method Description ChannelFutureAbstractHttp2StreamChannel. bind(java.net.SocketAddress localAddress, ChannelPromise promise)voidAbstractHttp2StreamChannel.Http2ChannelUnsafe. bind(java.net.SocketAddress localAddress, ChannelPromise promise)voidHttp2ConnectionHandler. bind(ChannelHandlerContext ctx, java.net.SocketAddress localAddress, ChannelPromise promise)ChannelFutureAbstractHttp2StreamChannel. close(ChannelPromise promise)voidAbstractHttp2StreamChannel.Http2ChannelUnsafe. close(ChannelPromise promise)voidHttp2ConnectionHandler. close(ChannelHandlerContext ctx, ChannelPromise promise)ChannelFutureAbstractHttp2StreamChannel. connect(java.net.SocketAddress remoteAddress, ChannelPromise promise)ChannelFutureAbstractHttp2StreamChannel. connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)voidAbstractHttp2StreamChannel.Http2ChannelUnsafe. connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)voidHttp2ConnectionHandler. connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)ChannelFutureAbstractHttp2StreamChannel. deregister(ChannelPromise promise)voidAbstractHttp2StreamChannel.Http2ChannelUnsafe. deregister(ChannelPromise promise)voidHttp2ConnectionHandler. deregister(ChannelHandlerContext ctx, ChannelPromise promise)ChannelFutureAbstractHttp2StreamChannel. disconnect(ChannelPromise promise)voidAbstractHttp2StreamChannel.Http2ChannelUnsafe. disconnect(ChannelPromise promise)voidHttp2ConnectionHandler. disconnect(ChannelHandlerContext ctx, ChannelPromise promise)private voidHttp2ConnectionHandler. doGracefulShutdown(ChannelHandlerContext ctx, ChannelFuture future, ChannelPromise promise)private voidAbstractHttp2StreamChannel.Http2ChannelUnsafe. fireChannelInactiveAndDeregister(ChannelPromise promise, boolean fireChannelInactive)private voidAbstractHttp2StreamChannel.Http2ChannelUnsafe. firstWriteComplete(ChannelFuture future, ChannelPromise promise)ChannelFutureHttp2ConnectionHandler. goAway(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData, ChannelPromise promise)private ChannelFutureHttp2ConnectionHandler. goAway(ChannelHandlerContext ctx, Http2Exception cause, ChannelPromise promise)Close the remote endpoint with with aGO_AWAYframe.ChannelFutureHttp2LifecycleManager. 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.private ChannelPromiseHttp2ControlFrameLimitEncoder. handleOutstandingControlFrames(ChannelHandlerContext ctx, ChannelPromise promise)private ChannelFutureListenerHttp2ConnectionHandler. newClosingChannelFutureListener(ChannelHandlerContext ctx, ChannelPromise promise)voidAbstractHttp2StreamChannel.Http2ChannelUnsafe. register(EventLoop eventLoop, ChannelPromise promise)ChannelFutureHttp2ConnectionHandler. resetStream(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise)private ChannelFutureHttp2ConnectionHandler. resetStream(ChannelHandlerContext ctx, Http2Stream stream, long errorCode, ChannelPromise promise)ChannelFutureHttp2LifecycleManager. resetStream(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise)Ensure the stream identified bystreamIdis reset.private ChannelFutureHttp2ConnectionHandler. resetUnknownStream(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise)Sends aRST_STREAMframe even if we don't know about the stream.private voidAbstractHttp2StreamChannel.Http2ChannelUnsafe. safeSetSuccess(ChannelPromise promise)private static ChannelFutureDefaultHttp2ConnectionEncoder. sendHeaders(Http2FrameWriter frameWriter, ChannelHandlerContext ctx, int streamId, Http2Headers headers, boolean hasPriority, int streamDependency, short weight, boolean exclusive, int padding, boolean endOfStream, ChannelPromise promise)Write headers viaHttp2FrameWriter.voidAbstractHttp2StreamChannel.Http2ChannelUnsafe. write(java.lang.Object msg, ChannelPromise promise)ChannelFutureAbstractHttp2StreamChannel. write(java.lang.Object msg, ChannelPromise promise)voidHttp2ConnectionHandler. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)voidHttp2FrameCodec. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)Processes allHttp2Frames.voidHttpToHttp2ConnectionHandler. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)Handles conversion ofHttpMessageandHttpContentto HTTP/2 frames.ChannelFutureAbstractHttp2StreamChannel. writeAndFlush(java.lang.Object msg, ChannelPromise promise)private voidAbstractHttp2StreamChannel.Http2ChannelUnsafe. writeComplete(ChannelFuture future, ChannelPromise promise)ChannelFutureCompressorHttp2ConnectionEncoder. writeData(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endOfStream, ChannelPromise promise)ChannelFutureDecoratingHttp2FrameWriter. writeData(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endStream, ChannelPromise promise)ChannelFutureDefaultHttp2ConnectionEncoder. writeData(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endOfStream, ChannelPromise promise)ChannelFutureDefaultHttp2FrameWriter. writeData(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endStream, ChannelPromise promise)ChannelFutureHttp2DataWriter. writeData(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endStream, ChannelPromise promise)Writes aDATAframe to the remote endpoint.ChannelFutureHttp2OutboundFrameLogger. writeData(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endStream, ChannelPromise promise)ChannelFutureStreamBufferingEncoder. writeData(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endOfStream, ChannelPromise promise)ChannelFutureDecoratingHttp2FrameWriter. writeFrame(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf payload, ChannelPromise promise)ChannelFutureDefaultHttp2ConnectionEncoder. writeFrame(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf payload, ChannelPromise promise)ChannelFutureDefaultHttp2FrameWriter. writeFrame(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf payload, ChannelPromise promise)ChannelFutureHttp2ConnectionEncoder. 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.ChannelFutureHttp2FrameWriter. writeFrame(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf payload, ChannelPromise promise)Generic write method for any HTTP/2 frame.ChannelFutureHttp2OutboundFrameLogger. writeFrame(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf payload, ChannelPromise promise)ChannelFutureDecoratingHttp2FrameWriter. writeGoAway(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData, ChannelPromise promise)ChannelFutureDefaultHttp2ConnectionEncoder. writeGoAway(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData, ChannelPromise promise)ChannelFutureDefaultHttp2FrameWriter. writeGoAway(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData, ChannelPromise promise)ChannelFutureHttp2FrameWriter. writeGoAway(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData, ChannelPromise promise)Writes a GO_AWAY frame to the remote endpoint.ChannelFutureHttp2OutboundFrameLogger. writeGoAway(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData, ChannelPromise promise)private voidHttp2FrameCodec. writeGoAwayFrame(ChannelHandlerContext ctx, Http2GoAwayFrame frame, ChannelPromise promise)ChannelFutureCompressorHttp2ConnectionEncoder. writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream, ChannelPromise promise)ChannelFutureCompressorHttp2ConnectionEncoder. writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endOfStream, ChannelPromise promise)ChannelFutureDecoratingHttp2FrameWriter. writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream, ChannelPromise promise)ChannelFutureDecoratingHttp2FrameWriter. writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endStream, ChannelPromise promise)ChannelFutureDefaultHttp2ConnectionEncoder. writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream, ChannelPromise promise)ChannelFutureDefaultHttp2ConnectionEncoder. writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endOfStream, ChannelPromise promise)ChannelFutureDefaultHttp2FrameWriter. writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream, ChannelPromise promise)ChannelFutureDefaultHttp2FrameWriter. writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endStream, ChannelPromise promise)ChannelFutureHttp2FrameWriter. writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream, ChannelPromise promise)Writes a HEADERS frame to the remote endpoint.ChannelFutureHttp2FrameWriter. 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.ChannelFutureHttp2OutboundFrameLogger. writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream, ChannelPromise promise)ChannelFutureHttp2OutboundFrameLogger. writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endStream, ChannelPromise promise)ChannelFutureStreamBufferingEncoder. writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream, ChannelPromise promise)ChannelFutureStreamBufferingEncoder. writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endOfStream, ChannelPromise promise)private ChannelFutureDefaultHttp2ConnectionEncoder. writeHeaders0(ChannelHandlerContext ctx, int streamId, Http2Headers headers, boolean hasPriority, int streamDependency, short weight, boolean exclusive, int padding, boolean endOfStream, ChannelPromise promise)private voidHttp2FrameCodec. writeHeadersFrame(ChannelHandlerContext ctx, Http2HeadersFrame headersFrame, ChannelPromise promise)private ChannelFutureDefaultHttp2FrameWriter. writeHeadersInternal(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream, boolean hasPriority, int streamDependency, short weight, boolean exclusive, ChannelPromise promise)private voidAbstractHttp2StreamChannel.Http2ChannelUnsafe. writeHttp2StreamFrame(Http2StreamFrame frame, ChannelPromise promise)ChannelFutureDecoratingHttp2FrameWriter. writePing(ChannelHandlerContext ctx, boolean ack, long data, ChannelPromise promise)ChannelFutureDefaultHttp2ConnectionEncoder. writePing(ChannelHandlerContext ctx, boolean ack, long data, ChannelPromise promise)ChannelFutureDefaultHttp2FrameWriter. writePing(ChannelHandlerContext ctx, boolean ack, long data, ChannelPromise promise)ChannelFutureHttp2ControlFrameLimitEncoder. writePing(ChannelHandlerContext ctx, boolean ack, long data, ChannelPromise promise)ChannelFutureHttp2FrameWriter. writePing(ChannelHandlerContext ctx, boolean ack, long data, ChannelPromise promise)Writes a PING frame to the remote endpoint.ChannelFutureHttp2OutboundFrameLogger. writePing(ChannelHandlerContext ctx, boolean ack, long data, ChannelPromise promise)ChannelFutureDecoratingHttp2FrameWriter. writePriority(ChannelHandlerContext ctx, int streamId, int streamDependency, short weight, boolean exclusive, ChannelPromise promise)ChannelFutureDefaultHttp2ConnectionEncoder. writePriority(ChannelHandlerContext ctx, int streamId, int streamDependency, short weight, boolean exclusive, ChannelPromise promise)ChannelFutureDefaultHttp2FrameWriter. writePriority(ChannelHandlerContext ctx, int streamId, int streamDependency, short weight, boolean exclusive, ChannelPromise promise)ChannelFutureHttp2FrameWriter. writePriority(ChannelHandlerContext ctx, int streamId, int streamDependency, short weight, boolean exclusive, ChannelPromise promise)Writes a PRIORITY frame to the remote endpoint.ChannelFutureHttp2OutboundFrameLogger. writePriority(ChannelHandlerContext ctx, int streamId, int streamDependency, short weight, boolean exclusive, ChannelPromise promise)ChannelFutureDecoratingHttp2FrameWriter. writePushPromise(ChannelHandlerContext ctx, int streamId, int promisedStreamId, Http2Headers headers, int padding, ChannelPromise promise)ChannelFutureDefaultHttp2ConnectionEncoder. writePushPromise(ChannelHandlerContext ctx, int streamId, int promisedStreamId, Http2Headers headers, int padding, ChannelPromise promise)ChannelFutureDefaultHttp2FrameWriter. writePushPromise(ChannelHandlerContext ctx, int streamId, int promisedStreamId, Http2Headers headers, int padding, ChannelPromise promise)ChannelFutureHttp2FrameWriter. writePushPromise(ChannelHandlerContext ctx, int streamId, int promisedStreamId, Http2Headers headers, int padding, ChannelPromise promise)Writes a PUSH_PROMISE frame to the remote endpoint.ChannelFutureHttp2OutboundFrameLogger. writePushPromise(ChannelHandlerContext ctx, int streamId, int promisedStreamId, Http2Headers headers, int padding, ChannelPromise promise)ChannelFutureDecoratingHttp2FrameWriter. writeRstStream(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise)ChannelFutureDefaultHttp2ConnectionEncoder. writeRstStream(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise)ChannelFutureDefaultHttp2FrameWriter. writeRstStream(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise)ChannelFutureHttp2ControlFrameLimitEncoder. writeRstStream(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise)ChannelFutureHttp2FrameWriter. writeRstStream(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise)Writes a RST_STREAM frame to the remote endpoint.ChannelFutureHttp2OutboundFrameLogger. writeRstStream(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise)ChannelFutureStreamBufferingEncoder. writeRstStream(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise)ChannelFutureDecoratingHttp2FrameWriter. writeSettings(ChannelHandlerContext ctx, Http2Settings settings, ChannelPromise promise)ChannelFutureDefaultHttp2ConnectionEncoder. writeSettings(ChannelHandlerContext ctx, Http2Settings settings, ChannelPromise promise)ChannelFutureDefaultHttp2FrameWriter. writeSettings(ChannelHandlerContext ctx, Http2Settings settings, ChannelPromise promise)ChannelFutureHttp2FrameWriter. writeSettings(ChannelHandlerContext ctx, Http2Settings settings, ChannelPromise promise)Writes a SETTINGS frame to the remote endpoint.ChannelFutureHttp2OutboundFrameLogger. writeSettings(ChannelHandlerContext ctx, Http2Settings settings, ChannelPromise promise)ChannelFutureDecoratingHttp2FrameWriter. writeSettingsAck(ChannelHandlerContext ctx, ChannelPromise promise)ChannelFutureDefaultHttp2ConnectionEncoder. writeSettingsAck(ChannelHandlerContext ctx, ChannelPromise promise)ChannelFutureDefaultHttp2FrameWriter. writeSettingsAck(ChannelHandlerContext ctx, ChannelPromise promise)ChannelFutureHttp2ControlFrameLimitEncoder. writeSettingsAck(ChannelHandlerContext ctx, ChannelPromise promise)ChannelFutureHttp2FrameWriter. writeSettingsAck(ChannelHandlerContext ctx, ChannelPromise promise)Writes a SETTINGS acknowledgment to the remote endpoint.ChannelFutureHttp2OutboundFrameLogger. writeSettingsAck(ChannelHandlerContext ctx, ChannelPromise promise)ChannelFutureDecoratingHttp2FrameWriter. writeWindowUpdate(ChannelHandlerContext ctx, int streamId, int windowSizeIncrement, ChannelPromise promise)ChannelFutureDefaultHttp2ConnectionEncoder. writeWindowUpdate(ChannelHandlerContext ctx, int streamId, int windowSizeIncrement, ChannelPromise promise)ChannelFutureDefaultHttp2FrameWriter. writeWindowUpdate(ChannelHandlerContext ctx, int streamId, int windowSizeIncrement, ChannelPromise promise)ChannelFutureHttp2FrameWriter. writeWindowUpdate(ChannelHandlerContext ctx, int streamId, int windowSizeIncrement, ChannelPromise promise)Writes a WINDOW_UPDATE frame to the remote endpoint.ChannelFutureHttp2OutboundFrameLogger. writeWindowUpdate(ChannelHandlerContext ctx, int streamId, int windowSizeIncrement, ChannelPromise promise)Constructors in io.netty.handler.codec.http2 with parameters of type ChannelPromise Constructor Description ClosingChannelFutureListener(ChannelHandlerContext ctx, ChannelPromise promise)ClosingChannelFutureListener(ChannelHandlerContext ctx, ChannelPromise promise, long timeout, java.util.concurrent.TimeUnit unit)DataFrame(ByteBuf data, int padding, boolean endOfStream, ChannelPromise promise)FlowControlledBase(Http2Stream stream, int padding, boolean endOfStream, ChannelPromise promise)FlowControlledData(Http2Stream stream, ByteBuf buf, int padding, boolean endOfStream, ChannelPromise promise)FlowControlledHeaders(Http2Stream stream, Http2Headers headers, boolean hasPriority, int streamDependency, short weight, boolean exclusive, int padding, boolean endOfStream, ChannelPromise promise)Frame(ChannelPromise promise)HeadersFrame(Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endOfStream, ChannelPromise promise)SimpleChannelPromiseAggregator(ChannelPromise promise, Channel c, EventExecutor e) -
Uses of ChannelPromise in io.netty.handler.codec.spdy
Fields in io.netty.handler.codec.spdy declared as ChannelPromise Modifier and Type Field Description (package private) ChannelPromiseSpdySession.PendingWrite. promiseprivate ChannelPromiseSpdySessionHandler.ClosingChannelFutureListener. promiseMethods in io.netty.handler.codec.spdy with parameters of type ChannelPromise Modifier and Type Method Description voidSpdyFrameCodec. bind(ChannelHandlerContext ctx, java.net.SocketAddress localAddress, ChannelPromise promise)voidSpdyFrameCodec. close(ChannelHandlerContext ctx, ChannelPromise promise)voidSpdySessionHandler. close(ChannelHandlerContext ctx, ChannelPromise promise)voidSpdyFrameCodec. connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)voidSpdyFrameCodec. deregister(ChannelHandlerContext ctx, ChannelPromise promise)voidSpdyFrameCodec. disconnect(ChannelHandlerContext ctx, ChannelPromise promise)private voidSpdySessionHandler. handleOutboundMessage(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)private voidSpdySessionHandler. sendGoAwayFrame(ChannelHandlerContext ctx, ChannelPromise future)voidSpdyFrameCodec. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)voidSpdySessionHandler. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)Constructors in io.netty.handler.codec.spdy with parameters of type ChannelPromise Constructor Description ClosingChannelFutureListener(ChannelHandlerContext ctx, ChannelPromise promise)PendingWrite(SpdyDataFrame spdyDataFrame, ChannelPromise promise) -
Uses of ChannelPromise in io.netty.handler.flush
Methods in io.netty.handler.flush with parameters of type ChannelPromise Modifier and Type Method Description voidFlushConsolidationHandler. 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 ChannelPromise Modifier and Type Method Description voidLoggingHandler. bind(ChannelHandlerContext ctx, java.net.SocketAddress localAddress, ChannelPromise promise)voidLoggingHandler. close(ChannelHandlerContext ctx, ChannelPromise promise)voidLoggingHandler. connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)voidLoggingHandler. deregister(ChannelHandlerContext ctx, ChannelPromise promise)voidLoggingHandler. disconnect(ChannelHandlerContext ctx, ChannelPromise promise)voidLoggingHandler. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise) -
Uses of ChannelPromise in io.netty.handler.proxy
Methods in io.netty.handler.proxy with parameters of type ChannelPromise Modifier and Type Method Description private voidProxyHandler. addPendingWrite(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)voidHttpProxyHandler.HttpClientCodecWrapper. bind(ChannelHandlerContext ctx, java.net.SocketAddress localAddress, ChannelPromise promise)voidHttpProxyHandler.HttpClientCodecWrapper. close(ChannelHandlerContext ctx, ChannelPromise promise)voidHttpProxyHandler.HttpClientCodecWrapper. connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)voidProxyHandler. connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)voidHttpProxyHandler.HttpClientCodecWrapper. deregister(ChannelHandlerContext ctx, ChannelPromise promise)voidHttpProxyHandler.HttpClientCodecWrapper. disconnect(ChannelHandlerContext ctx, ChannelPromise promise)voidHttpProxyHandler.HttpClientCodecWrapper. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)voidProxyHandler. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise) -
Uses of ChannelPromise in io.netty.handler.ssl
Methods in io.netty.handler.ssl with parameters of type ChannelPromise Modifier and Type Method Description private static voidSslHandler. addCloseListener(ChannelFuture future, ChannelPromise promise)voidSslClientHelloHandler. bind(ChannelHandlerContext ctx, java.net.SocketAddress localAddress, ChannelPromise promise)voidSslHandler. bind(ChannelHandlerContext ctx, java.net.SocketAddress localAddress, ChannelPromise promise)voidSslClientHelloHandler. close(ChannelHandlerContext ctx, ChannelPromise promise)voidSslHandler. close(ChannelHandlerContext ctx, ChannelPromise promise)ChannelFutureSslHandler. close(ChannelPromise promise)Deprecated.ChannelFutureSslHandler. closeOutbound(ChannelPromise promise)Sends an SSLclose_notifymessage to the specified channel and destroys the underlyingSSLEngine.private voidSslHandler. closeOutbound0(ChannelPromise promise)private voidSslHandler. closeOutboundAndChannel(ChannelHandlerContext ctx, ChannelPromise promise, boolean disconnect)voidSslClientHelloHandler. connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)voidSslHandler. connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.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)private voidSslHandler. finishWrap(ChannelHandlerContext ctx, ByteBuf out, ChannelPromise promise, boolean inUnwrap, boolean needUnwrap)private voidSslHandler. flush(ChannelHandlerContext ctx, ChannelPromise promise)private voidSslHandler. safeClose(ChannelHandlerContext ctx, ChannelFuture flushFuture, ChannelPromise promise)voidSslClientHelloHandler. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)voidSslHandler. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise) -
Uses of ChannelPromise in io.netty.handler.stream
Fields in io.netty.handler.stream declared as ChannelPromise Modifier and Type Field Description (package private) ChannelPromiseChunkedWriteHandler.PendingWrite. promiseMethods in io.netty.handler.stream with parameters of type ChannelPromise Modifier and Type Method Description voidChunkedWriteHandler. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)Constructors in io.netty.handler.stream with parameters of type ChannelPromise Constructor Description PendingWrite(java.lang.Object msg, ChannelPromise promise) -
Uses of ChannelPromise in io.netty.handler.timeout
Fields in io.netty.handler.timeout declared as ChannelPromise Modifier and Type Field Description private ChannelPromiseWriteTimeoutHandler.WriteTimeoutTask. promiseMethods in io.netty.handler.timeout with parameters of type ChannelPromise Modifier and Type Method Description private voidWriteTimeoutHandler. scheduleTimeout(ChannelHandlerContext ctx, ChannelPromise promise)voidIdleStateHandler. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)voidWriteTimeoutHandler. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)Constructors in io.netty.handler.timeout with parameters of type ChannelPromise Constructor Description WriteTimeoutTask(ChannelHandlerContext ctx, ChannelPromise promise) -
Uses of ChannelPromise in io.netty.handler.traffic
Fields in io.netty.handler.traffic declared as ChannelPromise Modifier and Type Field Description (package private) ChannelPromiseChannelTrafficShapingHandler.ToSend. promise(package private) ChannelPromiseGlobalChannelTrafficShapingHandler.ToSend. promise(package private) ChannelPromiseGlobalTrafficShapingHandler.ToSend. promiseMethods in io.netty.handler.traffic with parameters of type ChannelPromise Modifier and Type Method Description (package private) abstract voidAbstractTrafficShapingHandler. submitWrite(ChannelHandlerContext ctx, java.lang.Object msg, long size, long delay, long now, ChannelPromise promise)protected voidAbstractTrafficShapingHandler. submitWrite(ChannelHandlerContext ctx, java.lang.Object msg, long delay, ChannelPromise promise)Deprecated.(package private) voidChannelTrafficShapingHandler. submitWrite(ChannelHandlerContext ctx, java.lang.Object msg, long size, long delay, long now, ChannelPromise promise)protected voidGlobalChannelTrafficShapingHandler. submitWrite(ChannelHandlerContext ctx, java.lang.Object msg, long size, long writedelay, long now, ChannelPromise promise)(package private) voidGlobalTrafficShapingHandler. submitWrite(ChannelHandlerContext ctx, java.lang.Object msg, long size, long writedelay, long now, ChannelPromise promise)voidAbstractTrafficShapingHandler. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)voidGlobalChannelTrafficShapingHandler. write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)Constructors in io.netty.handler.traffic with parameters of type ChannelPromise Constructor Description ToSend(long delay, java.lang.Object toSend, ChannelPromise promise)ToSend(long delay, java.lang.Object toSend, long size, ChannelPromise promise)ToSend(long delay, java.lang.Object toSend, long size, ChannelPromise promise) -
Uses of ChannelPromise in io.netty.resolver.dns
Methods in io.netty.resolver.dns with parameters of type ChannelPromise Modifier and Type Method Description (package private) voidDnsQueryContext. query(boolean flush, ChannelPromise writePromise)(package private) Future<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>>DnsNameResolver. query0(java.net.InetSocketAddress nameServerAddr, DnsQuestion question, DnsRecord[] additionals, boolean flush, ChannelPromise writePromise, Promise<AddressedEnvelope<? extends DnsResponse,java.net.InetSocketAddress>> promise)private voidDnsQueryContext. sendQuery(DnsQuery query, boolean flush, ChannelPromise writePromise)private voidDnsQueryContext. writeQuery(DnsQuery query, boolean flush, ChannelPromise writePromise)
-