Modifier and Type | Interface and Description |
---|---|
interface |
ChannelProgressivePromise
特殊 ChannelPromise ,一旦关联的字节正在传输,它将被通知。
|
Modifier and Type | Class and Description |
---|---|
class |
DefaultChannelProgressivePromise
|
class |
DefaultChannelPromise
默认的 ChannelPromise 实现。
|
class |
DelegatingChannelPromiseNotifier |
class |
VoidChannelPromise |
Modifier and Type | Method and Description |
---|---|
ChannelPromise |
DelegatingChannelPromiseNotifier.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelPromise |
DefaultChannelPromise.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelPromise |
ChannelPromise.addListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelPromise |
DelegatingChannelPromiseNotifier.addListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners) |
ChannelPromise |
DefaultChannelPromise.addListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners) |
ChannelPromise |
ChannelPromise.addListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners) |
ChannelPromise |
DelegatingChannelPromiseNotifier.await() |
ChannelPromise |
DefaultChannelPromise.await() |
ChannelPromise |
ChannelPromise.await() |
ChannelPromise |
DelegatingChannelPromiseNotifier.awaitUninterruptibly() |
ChannelPromise |
DefaultChannelPromise.awaitUninterruptibly() |
ChannelPromise |
ChannelPromise.awaitUninterruptibly() |
ChannelPromise |
DefaultChannelPipeline.newPromise() |
ChannelPromise |
ChannelOutboundInvoker.newPromise()
返回一个新的 ChannelPromise 。
|
ChannelPromise |
AbstractChannel.newPromise() |
ChannelPromise |
DefaultChannelPromise.promise() |
ChannelPromise |
PendingWriteQueue.remove()
通过
ReferenceCountUtil.safeRelease(Object) 删除挂起的写入操作并释放它的消息。
|
ChannelPromise |
DelegatingChannelPromiseNotifier.removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelPromise |
DefaultChannelPromise.removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelPromise |
ChannelPromise.removeListener(GenericFutureListener<? extends Future<? super java.lang.Void>> listener) |
ChannelPromise |
DelegatingChannelPromiseNotifier.removeListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners) |
ChannelPromise |
DefaultChannelPromise.removeListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners) |
ChannelPromise |
ChannelPromise.removeListeners(GenericFutureListener<? extends Future<? super java.lang.Void>>... listeners) |
ChannelPromise |
DelegatingChannelPromiseNotifier.setFailure(java.lang.Throwable cause) |
ChannelPromise |
DefaultChannelPromise.setFailure(java.lang.Throwable cause) |
ChannelPromise |
ChannelPromise.setFailure(java.lang.Throwable cause) |
ChannelPromise |
DelegatingChannelPromiseNotifier.setSuccess() |
ChannelPromise |
DefaultChannelPromise.setSuccess() |
ChannelPromise |
ChannelPromise.setSuccess() |
ChannelPromise |
DelegatingChannelPromiseNotifier.setSuccess(java.lang.Void result) |
ChannelPromise |
DefaultChannelPromise.setSuccess(java.lang.Void result) |
ChannelPromise |
ChannelPromise.setSuccess(java.lang.Void result) |
ChannelPromise |
DelegatingChannelPromiseNotifier.sync() |
ChannelPromise |
DefaultChannelPromise.sync() |
ChannelPromise |
ChannelPromise.sync() |
ChannelPromise |
DelegatingChannelPromiseNotifier.syncUninterruptibly() |
ChannelPromise |
DefaultChannelPromise.syncUninterruptibly() |
ChannelPromise |
ChannelPromise.syncUninterruptibly() |
ChannelPromise |
VoidChannelPromise.unvoid() |
ChannelPromise |
DelegatingChannelPromiseNotifier.unvoid() |
ChannelPromise |
DefaultChannelPromise.unvoid() |
ChannelPromise |
ChannelPromise.unvoid()
如果 ChannelFuture.isVoid() 本身返回true 则返回新的ChannelPromise 。
|
ChannelPromise |
DefaultChannelPipeline.voidPromise() |
ChannelPromise |
ChannelOutboundInvoker.voidPromise()
返回可用于不同操作的特殊ChannelPromise。
|
ChannelPromise |
Channel.Unsafe.voidPromise()
返回一个特殊的ChannelPromise,可以重复使用并传递到 Channel.Unsafe 中的操作。
|
ChannelPromise |
AbstractChannel.voidPromise() |
ChannelPromise |
AbstractChannel.AbstractUnsafe.voidPromise() |
Modifier and Type | Method and Description |
---|---|
void |
AbstractCoalescingBufferQueue.add(ByteBuf buf, ChannelPromise promise)
将一个缓冲区添加到队列的末尾,并将一个承诺与它关联起来,当所有缓冲区的字节已从队列中消耗并写入时应该完成该承诺。
|
ChannelFlushPromiseNotifier |
ChannelFlushPromiseNotifier.add(ChannelPromise promise, int pendingDataSize)
|
ChannelFlushPromiseNotifier |
ChannelFlushPromiseNotifier.add(ChannelPromise promise, long pendingDataSize)
将 ChannelPromise 添加到此ChannelFlushPromiseNotifier 中 ,在达到给定的pendingDataSize 后将会通知该pendingDataSize 。
|
void |
PendingWriteQueue.add(java.lang.Object msg, ChannelPromise promise)
添加给定的 msg 和ChannelPromise 。
|
void |
AbstractCoalescingBufferQueue.addFirst(ByteBuf buf, ChannelPromise promise)
将一个缓冲区添加到队列的前面,并将一个承诺与它关联起来,当所有缓冲区的字节已从队列中消耗并写入时应该完成该承诺。
|
void |
ChannelOutboundBuffer.addMessage(java.lang.Object msg, int size, ChannelPromise promise)
给此消息添加 ChannelOutboundBuffer 。
|
void |
CombinedChannelDuplexHandler.bind(ChannelHandlerContext ctx, java.net.SocketAddress localAddress, ChannelPromise promise) |
void |
ChannelOutboundHandlerAdapter.bind(ChannelHandlerContext ctx, java.net.SocketAddress localAddress, ChannelPromise promise)
|
void |
ChannelOutboundHandler.bind(ChannelHandlerContext ctx, java.net.SocketAddress localAddress, ChannelPromise promise)
调用一次绑定操作。
|
void |
ChannelDuplexHandler.bind(ChannelHandlerContext ctx, java.net.SocketAddress localAddress, ChannelPromise promise)
|
ChannelFuture |
DefaultChannelPipeline.bind(java.net.SocketAddress localAddress, ChannelPromise promise) |
ChannelFuture |
ChannelOutboundInvoker.bind(java.net.SocketAddress localAddress, ChannelPromise promise)
请求绑定到给定的 SocketAddress 并在操作完成后通知ChannelFuture ,无论是因为操作成功还是由于错误。
|
void |
Channel.Unsafe.bind(java.net.SocketAddress localAddress, ChannelPromise promise)
绑定 SocketAddress 到Channel 的的ChannelPromise 并通知其一旦其完成。
|
ChannelFuture |
AbstractChannel.bind(java.net.SocketAddress localAddress, ChannelPromise promise) |
void |
AbstractChannel.AbstractUnsafe.bind(java.net.SocketAddress localAddress, ChannelPromise promise) |
void |
CombinedChannelDuplexHandler.close(ChannelHandlerContext ctx, ChannelPromise promise) |
void |
ChannelOutboundHandlerAdapter.close(ChannelHandlerContext ctx, ChannelPromise promise)
|
void |
ChannelOutboundHandler.close(ChannelHandlerContext ctx, ChannelPromise promise)
一旦进行了密切的操作,就会被调用。
|
void |
ChannelDuplexHandler.close(ChannelHandlerContext ctx, ChannelPromise promise)
|
ChannelFuture |
DefaultChannelPipeline.close(ChannelPromise promise) |
ChannelFuture |
ChannelOutboundInvoker.close(ChannelPromise promise)
请求关闭 Channel ,并在操作完成后通知ChannelFuture ,无论是因为操作成功还是由于错误。
|
void |
Channel.Unsafe.close(ChannelPromise promise)
关闭 ChannelPromise 的Channel ,并在操作完成后通知ChannelPromise 。
|
ChannelFuture |
AbstractChannel.close(ChannelPromise promise) |
void |
AbstractChannel.AbstractUnsafe.close(ChannelPromise promise) |
void |
CombinedChannelDuplexHandler.connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise) |
void |
ChannelOutboundHandlerAdapter.connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
|
void |
ChannelOutboundHandler.connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
连接操作完成后调用。
|
void |
ChannelDuplexHandler.connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
|
ChannelFuture |
DefaultChannelPipeline.connect(java.net.SocketAddress remoteAddress, ChannelPromise promise) |
ChannelFuture |
ChannelOutboundInvoker.connect(java.net.SocketAddress remoteAddress, ChannelPromise promise)
请求连接到给定的 SocketAddress 并在操作完成后通知ChannelFuture ,无论是因为操作成功还是由于错误。
|
ChannelFuture |
AbstractChannel.connect(java.net.SocketAddress remoteAddress, ChannelPromise promise) |
ChannelFuture |
DefaultChannelPipeline.connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise) |
ChannelFuture |
ChannelOutboundInvoker.connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
请求连接到给定的 SocketAddress 同时绑定到localAddress,并在操作完成后通知ChannelFuture ,无论是因为操作成功还是由于错误。
|
void |
Channel.Unsafe.connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
连接 Channel 指定的ChannelFuture 与指定的远程SocketAddress 。
|
ChannelFuture |
AbstractChannel.connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise) |
void |
CombinedChannelDuplexHandler.deregister(ChannelHandlerContext ctx, ChannelPromise promise) |
void |
ChannelOutboundHandlerAdapter.deregister(ChannelHandlerContext ctx, ChannelPromise promise)
|
void |
ChannelOutboundHandler.deregister(ChannelHandlerContext ctx, ChannelPromise promise)
一旦从当前注册的 EventLoop 进行撤销注册操作,就会被调用。
|
void |
ChannelDuplexHandler.deregister(ChannelHandlerContext ctx, ChannelPromise promise)
|
ChannelFuture |
DefaultChannelPipeline.deregister(ChannelPromise promise) |
ChannelFuture |
ChannelOutboundInvoker.deregister(ChannelPromise promise)
请求注销以前分配的 EventExecutor ,并在操作完成后通知ChannelFuture ,无论是因为操作成功还是由于错误。
|
void |
Channel.Unsafe.deregister(ChannelPromise promise)
注销 ChannelPromise 中的Channel EventLoop ,并在操作完成后通知ChannelPromise 。
|
ChannelFuture |
AbstractChannel.deregister(ChannelPromise promise) |
void |
AbstractChannel.AbstractUnsafe.deregister(ChannelPromise promise) |
void |
CombinedChannelDuplexHandler.disconnect(ChannelHandlerContext ctx, ChannelPromise promise) |
void |
ChannelOutboundHandlerAdapter.disconnect(ChannelHandlerContext ctx, ChannelPromise promise)
|
void |
ChannelOutboundHandler.disconnect(ChannelHandlerContext ctx, ChannelPromise promise)
调用一次断开操作。
|
void |
ChannelDuplexHandler.disconnect(ChannelHandlerContext ctx, ChannelPromise promise)
|
ChannelFuture |
DefaultChannelPipeline.disconnect(ChannelPromise promise) |
ChannelFuture |
ChannelOutboundInvoker.disconnect(ChannelPromise promise)
请求从远程对等方断开连接,并在操作完成后通知 ChannelFuture ,因为操作成功或错误。
|
void |
Channel.Unsafe.disconnect(ChannelPromise promise)
断开 ChannelFuture 的Channel ,并在操作完成后通知ChannelPromise 。
|
ChannelFuture |
AbstractChannel.disconnect(ChannelPromise promise) |
void |
AbstractChannel.AbstractUnsafe.disconnect(ChannelPromise promise) |
protected boolean |
AbstractChannel.AbstractUnsafe.ensureOpen(ChannelPromise promise) |
ChannelFuture |
ThreadPerChannelEventLoopGroup.register(Channel channel, ChannelPromise promise)
已过时。
|
ChannelFuture |
ThreadPerChannelEventLoop.register(Channel channel, ChannelPromise promise)
已过时。
|
ChannelFuture |
SingleThreadEventLoop.register(Channel channel, ChannelPromise promise)
已过时。
|
ChannelFuture |
MultithreadEventLoopGroup.register(Channel channel, ChannelPromise promise)
已过时。
|
ChannelFuture |
EventLoopGroup.register(Channel channel, ChannelPromise promise)
已过时。
|
ChannelFuture |
ThreadPerChannelEventLoopGroup.register(ChannelPromise promise) |
ChannelFuture |
ThreadPerChannelEventLoop.register(ChannelPromise promise) |
ChannelFuture |
SingleThreadEventLoop.register(ChannelPromise promise) |
ChannelFuture |
MultithreadEventLoopGroup.register(ChannelPromise promise) |
ChannelFuture |
EventLoopGroup.register(ChannelPromise promise)
注册一个 Channel 这个EventLoop 使用ChannelFuture 。
|
void |
Channel.Unsafe.register(EventLoop eventLoop, ChannelPromise promise)
注册 ChannelPromise 的Channel ,并在注册完成后通知ChannelFuture 。
|
void |
AbstractChannel.AbstractUnsafe.register(EventLoop eventLoop, ChannelPromise promise) |
ByteBuf |
AbstractCoalescingBufferQueue.remove(ByteBufAllocator alloc, int bytes, ChannelPromise aggregatePromise)
从指定字节数的队列中移除 ByteBuf 。
|
ByteBuf |
CoalescingBufferQueue.remove(int bytes, ChannelPromise aggregatePromise)
用指定的字节数从队列中移除 ByteBuf 。
|
ByteBuf |
AbstractCoalescingBufferQueue.removeFirst(ChannelPromise aggregatePromise)
从队列中移除第一个 ByteBuf 。
|
protected void |
AbstractChannel.AbstractUnsafe.safeSetFailure(ChannelPromise promise, java.lang.Throwable cause)
将指定的
promise 标记为失败。
|
protected void |
AbstractChannel.AbstractUnsafe.safeSetSuccess(ChannelPromise promise)
将指定的
promise 标记为成功。
|
void |
AbstractChannel.AbstractUnsafe.shutdownOutput(ChannelPromise promise)
关闭相应 Channel 的输出部分。
|
void |
CombinedChannelDuplexHandler.write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise) |
void |
ChannelOutboundHandlerAdapter.write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)
|
void |
ChannelOutboundHandler.write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)
一旦写入操作被调用,就调用它。
|
void |
ChannelDuplexHandler.write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)
|
ChannelFuture |
DefaultChannelPipeline.write(java.lang.Object msg, ChannelPromise promise) |
ChannelFuture |
ChannelOutboundInvoker.write(java.lang.Object msg, ChannelPromise promise)
要求通过 ChannelHandlerContext 通过ChannelPipeline 写信息。
|
void |
Channel.Unsafe.write(java.lang.Object msg, ChannelPromise promise)
计划写入操作。
|
ChannelFuture |
AbstractChannel.write(java.lang.Object msg, ChannelPromise promise) |
void |
AbstractChannel.AbstractUnsafe.write(java.lang.Object msg, ChannelPromise promise) |
ChannelFuture |
DefaultChannelPipeline.writeAndFlush(java.lang.Object msg, ChannelPromise promise) |
ChannelFuture |
ChannelOutboundInvoker.writeAndFlush(java.lang.Object msg, ChannelPromise promise)
|
ChannelFuture |
AbstractChannel.writeAndFlush(java.lang.Object msg, ChannelPromise promise) |
Constructor and Description |
---|
ChannelPromiseAggregator(ChannelPromise aggregatePromise)
已过时。
|
ChannelPromiseNotifier(boolean logNotifyFailure, ChannelPromise... promises)
创建一个新的实例
|
ChannelPromiseNotifier(ChannelPromise... promises)
创建一个新的实例
|
DelegatingChannelPromiseNotifier(ChannelPromise delegate) |
DelegatingChannelPromiseNotifier(ChannelPromise delegate, boolean logNotifyFailure) |
Modifier and Type | Method and Description |
---|---|
ChannelFuture |
EmbeddedChannel.close(ChannelPromise promise) |
ChannelFuture |
EmbeddedChannel.disconnect(ChannelPromise promise) |
ChannelFuture |
EmbeddedChannel.writeOneInbound(java.lang.Object msg, ChannelPromise promise)
向此 Channel 的入站写入一条消息,但不刷新它。
|
ChannelFuture |
EmbeddedChannel.writeOneOutbound(java.lang.Object msg, ChannelPromise promise)
向此 Channel 的出站端写入一条消息,但不会刷新它。
|
Modifier and Type | Method and Description |
---|---|
ChannelFuture |
EpollDatagramChannel.block(java.net.InetAddress multicastAddress, java.net.InetAddress sourceToBlock, ChannelPromise promise) |
ChannelFuture |
EpollDatagramChannel.block(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress sourceToBlock, ChannelPromise promise) |
ChannelFuture |
EpollDatagramChannel.joinGroup(java.net.InetAddress multicastAddress, ChannelPromise promise) |
ChannelFuture |
EpollDatagramChannel.joinGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source, ChannelPromise promise) |
ChannelFuture |
EpollDatagramChannel.joinGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface, ChannelPromise promise) |
ChannelFuture |
EpollDatagramChannel.leaveGroup(java.net.InetAddress multicastAddress, ChannelPromise promise) |
ChannelFuture |
EpollDatagramChannel.leaveGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source, ChannelPromise promise) |
ChannelFuture |
EpollDatagramChannel.leaveGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface, ChannelPromise promise) |
ChannelFuture |
AbstractEpollStreamChannel.shutdown(ChannelPromise promise) |
ChannelFuture |
AbstractEpollStreamChannel.shutdownInput(ChannelPromise promise) |
ChannelFuture |
AbstractEpollStreamChannel.shutdownOutput(ChannelPromise promise) |
ChannelFuture |
AbstractEpollStreamChannel.spliceTo(AbstractEpollStreamChannel ch, int len, ChannelPromise promise)
|
ChannelFuture |
AbstractEpollStreamChannel.spliceTo(FileDescriptor ch, int offset, int len, ChannelPromise promise)
|
Constructor and Description |
---|
SpliceInTask(int len, ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
ChannelFuture |
KQueueDatagramChannel.block(java.net.InetAddress multicastAddress, java.net.InetAddress sourceToBlock, ChannelPromise promise) |
ChannelFuture |
KQueueDatagramChannel.block(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress sourceToBlock, ChannelPromise promise) |
ChannelFuture |
KQueueDatagramChannel.joinGroup(java.net.InetAddress multicastAddress, ChannelPromise promise) |
ChannelFuture |
KQueueDatagramChannel.joinGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source, ChannelPromise promise) |
ChannelFuture |
KQueueDatagramChannel.joinGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface, ChannelPromise promise) |
ChannelFuture |
KQueueDatagramChannel.leaveGroup(java.net.InetAddress multicastAddress, ChannelPromise promise) |
ChannelFuture |
KQueueDatagramChannel.leaveGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source, ChannelPromise promise) |
ChannelFuture |
KQueueDatagramChannel.leaveGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface, ChannelPromise promise) |
ChannelFuture |
AbstractKQueueStreamChannel.shutdown(ChannelPromise promise) |
ChannelFuture |
AbstractKQueueStreamChannel.shutdownInput(ChannelPromise promise) |
ChannelFuture |
AbstractKQueueStreamChannel.shutdownOutput(ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractNioChannel.AbstractNioUnsafe.connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
ChannelFuture |
SctpServerChannel.bindAddress(java.net.InetAddress localAddress, ChannelPromise promise)
将地址绑定到已绑定的通道以启用多宿主。
|
ChannelFuture |
SctpChannel.bindAddress(java.net.InetAddress localAddress, ChannelPromise promise)
将地址绑定到已绑定的通道以启用多宿主。
|
ChannelFuture |
SctpServerChannel.unbindAddress(java.net.InetAddress localAddress, ChannelPromise promise)
从通道的多址地址列表中解除绑定地址。
|
ChannelFuture |
SctpChannel.unbindAddress(java.net.InetAddress localAddress, ChannelPromise promise)
从通道的多址地址列表中解除绑定地址。
|
Modifier and Type | Method and Description |
---|---|
ChannelFuture |
NioSctpServerChannel.bindAddress(java.net.InetAddress localAddress, ChannelPromise promise) |
ChannelFuture |
NioSctpChannel.bindAddress(java.net.InetAddress localAddress, ChannelPromise promise) |
ChannelFuture |
NioSctpServerChannel.unbindAddress(java.net.InetAddress localAddress, ChannelPromise promise) |
ChannelFuture |
NioSctpChannel.unbindAddress(java.net.InetAddress localAddress, ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
ChannelFuture |
OioSctpServerChannel.bindAddress(java.net.InetAddress localAddress, ChannelPromise promise) |
ChannelFuture |
OioSctpChannel.bindAddress(java.net.InetAddress localAddress, ChannelPromise promise) |
ChannelFuture |
OioSctpServerChannel.unbindAddress(java.net.InetAddress localAddress, ChannelPromise promise) |
ChannelFuture |
OioSctpChannel.unbindAddress(java.net.InetAddress localAddress, ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
ChannelFuture |
DatagramChannel.block(java.net.InetAddress multicastAddress, java.net.InetAddress sourceToBlock, ChannelPromise future)
阻止给定多播地址的给定sourceToBlock地址,并在操作完成后通知 ChannelFuture 。
|
ChannelFuture |
DatagramChannel.block(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress sourceToBlock, ChannelPromise future)
在给定networkInterface上阻止给定多播地址的给定sourceToBlock地址,并在操作完成后通知 ChannelFuture 。
|
ChannelFuture |
DatagramChannel.joinGroup(java.net.InetAddress multicastAddress, ChannelPromise future)
一旦操作完成,就加入多播组并通知 ChannelFuture 。
|
ChannelFuture |
DatagramChannel.joinGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source, ChannelPromise future)
加入指定接口上的指定组播组,并在操作完成后通知 ChannelFuture 。
|
ChannelFuture |
DatagramChannel.joinGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface, ChannelPromise future)
在指定的接口加入指定的组播组,并在操作完成后通知 ChannelFuture 。
|
ChannelFuture |
DatagramChannel.leaveGroup(java.net.InetAddress multicastAddress, ChannelPromise future)
一个操作完成后,留下多播组并通知 ChannelFuture 。
|
ChannelFuture |
DatagramChannel.leaveGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source, ChannelPromise future)
在指定的接口上使用指定的源保留指定的多播组,并在操作完成后通知 ChannelFuture 。
|
ChannelFuture |
DatagramChannel.leaveGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface, ChannelPromise future)
在指定的本地接口上留下多播组,并在操作完成后通知 ChannelFuture 。
|
ChannelFuture |
DuplexChannel.shutdown(ChannelPromise promise)
将关闭此通道的输入和输出端。
|
ChannelFuture |
DuplexChannel.shutdownInput(ChannelPromise promise)
将关闭输入并通知 ChannelPromise 。
|
ChannelFuture |
DuplexChannel.shutdownOutput(ChannelPromise promise)
将关闭输出并通知 ChannelPromise 。
|
Modifier and Type | Method and Description |
---|---|
ChannelFuture |
NioDatagramChannel.block(java.net.InetAddress multicastAddress, java.net.InetAddress sourceToBlock, ChannelPromise promise)
阻止给定多播地址的给定sourceToBlock地址
|
ChannelFuture |
NioDatagramChannel.block(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress sourceToBlock, ChannelPromise promise)
阻止给定networkInterface上给定多播地址的给定sourceToBlock地址
|
ChannelFuture |
NioDatagramChannel.joinGroup(java.net.InetAddress multicastAddress, ChannelPromise promise) |
ChannelFuture |
NioDatagramChannel.joinGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source, ChannelPromise promise) |
ChannelFuture |
NioDatagramChannel.joinGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface, ChannelPromise promise) |
ChannelFuture |
NioDatagramChannel.leaveGroup(java.net.InetAddress multicastAddress, ChannelPromise promise) |
ChannelFuture |
NioDatagramChannel.leaveGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source, ChannelPromise promise) |
ChannelFuture |
NioDatagramChannel.leaveGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface, ChannelPromise promise) |
ChannelFuture |
NioSocketChannel.shutdown(ChannelPromise promise) |
ChannelFuture |
NioSocketChannel.shutdownInput(ChannelPromise promise) |
ChannelFuture |
NioSocketChannel.shutdownOutput(ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
ChannelFuture |
OioDatagramChannel.block(java.net.InetAddress multicastAddress, java.net.InetAddress sourceToBlock, ChannelPromise promise) |
ChannelFuture |
OioDatagramChannel.block(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress sourceToBlock, ChannelPromise promise) |
ChannelFuture |
OioDatagramChannel.joinGroup(java.net.InetAddress multicastAddress, ChannelPromise promise) |
ChannelFuture |
OioDatagramChannel.joinGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source, ChannelPromise promise) |
ChannelFuture |
OioDatagramChannel.joinGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface, ChannelPromise promise) |
ChannelFuture |
OioDatagramChannel.leaveGroup(java.net.InetAddress multicastAddress, ChannelPromise promise) |
ChannelFuture |
OioDatagramChannel.leaveGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source, ChannelPromise promise) |
ChannelFuture |
OioDatagramChannel.leaveGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface, ChannelPromise promise) |
ChannelFuture |
OioSocketChannel.shutdown(ChannelPromise promise) |
ChannelFuture |
OioSocketChannel.shutdownInput(ChannelPromise promise) |
ChannelFuture |
OioSocketChannel.shutdownOutput(ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
void |
DatagramPacketEncoder.bind(ChannelHandlerContext ctx, java.net.SocketAddress localAddress, ChannelPromise promise) |
void |
DatagramPacketEncoder.close(ChannelHandlerContext ctx, ChannelPromise promise) |
void |
DatagramPacketEncoder.connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise) |
void |
DatagramPacketEncoder.deregister(ChannelHandlerContext ctx, ChannelPromise promise) |
void |
DatagramPacketEncoder.disconnect(ChannelHandlerContext ctx, ChannelPromise promise) |
void |
MessageToMessageEncoder.write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise) |
void |
MessageToMessageCodec.write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise) |
void |
MessageToByteEncoder.write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise) |
void |
ByteToMessageCodec.write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
void |
Lz4FrameEncoder.close(ChannelHandlerContext ctx, ChannelPromise promise) |
void |
JdkZlibEncoder.close(ChannelHandlerContext ctx, ChannelPromise promise) |
void |
JZlibEncoder.close(ChannelHandlerContext ctx, ChannelPromise promise) |
void |
Bzip2Encoder.close(ChannelHandlerContext ctx, ChannelPromise promise) |
abstract ChannelFuture |
ZlibEncoder.close(ChannelPromise promise)
关闭此 ZlibEncoder 并完成编码。
|
ChannelFuture |
Lz4FrameEncoder.close(ChannelPromise promise)
关闭这个 Lz4FrameEncoder ,完成编码。
|
ChannelFuture |
JdkZlibEncoder.close(ChannelPromise promise) |
ChannelFuture |
JZlibEncoder.close(ChannelPromise promise) |
ChannelFuture |
Bzip2Encoder.close(ChannelPromise promise)
关闭这个 Bzip2Encoder 并完成编码。
|
Modifier and Type | Method and Description |
---|---|
void |
HttpClientUpgradeHandler.bind(ChannelHandlerContext ctx, java.net.SocketAddress localAddress, ChannelPromise promise) |
void |
HttpClientUpgradeHandler.close(ChannelHandlerContext ctx, ChannelPromise promise) |
void |
HttpClientUpgradeHandler.connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise) |
void |
HttpClientUpgradeHandler.deregister(ChannelHandlerContext ctx, ChannelPromise promise) |
void |
HttpClientUpgradeHandler.disconnect(ChannelHandlerContext ctx, ChannelPromise promise) |
void |
HttpServerKeepAliveHandler.write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise) |
void |
HttpClientUpgradeHandler.write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
void |
CorsHandler.write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
ChannelFuture |
WebSocketServerHandshaker00.close(Channel channel, CloseWebSocketFrame frame, ChannelPromise promise)
回显结束帧
|
ChannelFuture |
WebSocketServerHandshaker.close(Channel channel, CloseWebSocketFrame frame, ChannelPromise promise)
执行关闭握手
|
ChannelFuture |
WebSocketClientHandshaker.close(Channel channel, CloseWebSocketFrame frame, ChannelPromise promise)
执行关闭握手
|
ChannelFuture |
WebSocketClientHandshaker.handshake(Channel channel, ChannelPromise promise)
开始握手
|
ChannelFuture |
WebSocketServerHandshaker.handshake(Channel channel, FullHttpRequest req, HttpHeaders responseHeaders, ChannelPromise promise)
执行打开握手当调用此方法必须不保留 FullHttpRequest 这是在过去。
|
ChannelFuture |
WebSocketServerHandshaker.handshake(Channel channel, HttpRequest req, HttpHeaders responseHeaders, ChannelPromise promise)
执行打开握手当调用此方法时,您不能保留传入的 HttpRequest 。
|
ChannelFuture |
WebSocketClientHandshaker.processHandshake(Channel channel, HttpResponse response, ChannelPromise promise)
|
static ChannelFuture |
WebSocketServerHandshakerFactory.sendUnsupportedVersionResponse(Channel channel, ChannelPromise promise)
我们需要的返回不能支持Web套接字版本
|
Modifier and Type | Method and Description |
---|---|
void |
WebSocketServerExtensionHandler.write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise) |
void |
WebSocketClientExtensionHandler.write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise) |
Modifier and Type | Field and Description |
---|---|
protected ChannelPromise |
DefaultHttp2ConnectionEncoder.FlowControlledBase.promise |
Modifier and Type | Method and Description |
---|---|
void |
Http2ConnectionHandler.bind(ChannelHandlerContext ctx, java.net.SocketAddress localAddress, ChannelPromise promise) |
void |
Http2ConnectionHandler.close(ChannelHandlerContext ctx, ChannelPromise promise) |
void |
Http2ConnectionHandler.connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise) |
void |
Http2ConnectionHandler.deregister(ChannelHandlerContext ctx, ChannelPromise promise) |
void |
Http2ConnectionHandler.disconnect(ChannelHandlerContext ctx, ChannelPromise promise) |
ChannelFuture |
Http2LifecycleManager.goAway(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData, ChannelPromise promise)
如果
errorCode 不是
Http2Error.NO_ERROR ,则防止对等体创建流并关闭连接。
|
ChannelFuture |
Http2ConnectionHandler.goAway(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData, ChannelPromise promise) |
ChannelFuture |
Http2LifecycleManager.resetStream(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise)
确保重置由
streamId 标识的流。
|
ChannelFuture |
Http2ConnectionHandler.resetStream(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise) |
void |
HttpToHttp2ConnectionHandler.write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)
处理 HttpMessage 和HttpContent 到HTTP / 2帧的转换。
|
void |
Http2FrameCodec.write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)
全部处理 Http2Frame 。
|
void |
Http2ConnectionHandler.write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise) |
ChannelFuture |
StreamBufferingEncoder.writeData(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endOfStream, ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeData(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endStream, ChannelPromise promise) |
ChannelFuture |
Http2DataWriter.writeData(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endStream, ChannelPromise promise)
将
DATA 帧写入远程端点。
|
ChannelFuture |
DefaultHttp2FrameWriter.writeData(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endStream, ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeData(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endOfStream, ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writeData(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endStream, ChannelPromise promise) |
ChannelFuture |
CompressorHttp2ConnectionEncoder.writeData(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endOfStream, ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeFrame(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf payload, ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writeFrame(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf payload, ChannelPromise promise)
任何HTTP / 2帧的通用写入方法。
|
ChannelFuture |
Http2ConnectionEncoder.writeFrame(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf payload, ChannelPromise promise)
将给定数据写入内部 Http2FrameWriter ,而不对连接/流执行任何状态检查。
|
ChannelFuture |
DefaultHttp2FrameWriter.writeFrame(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf payload, ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeFrame(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf payload, ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writeFrame(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf payload, ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeGoAway(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData, ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writeGoAway(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData, ChannelPromise promise)
将GO_AWAY帧写入远程端点。
|
ChannelFuture |
DefaultHttp2FrameWriter.writeGoAway(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData, ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeGoAway(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData, ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writeGoAway(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData, ChannelPromise promise) |
ChannelFuture |
StreamBufferingEncoder.writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream, ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream, ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream, ChannelPromise promise)
将HEADERS帧写入远程端点。
|
ChannelFuture |
DefaultHttp2FrameWriter.writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream, ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream, ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream, ChannelPromise promise) |
ChannelFuture |
CompressorHttp2ConnectionEncoder.writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream, ChannelPromise promise) |
ChannelFuture |
StreamBufferingEncoder.writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endOfStream, ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endStream, ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endStream, ChannelPromise promise)
将指定优先级的HEADERS帧写入远程端点。
|
ChannelFuture |
DefaultHttp2FrameWriter.writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endStream, ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endOfStream, ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endStream, ChannelPromise promise) |
ChannelFuture |
CompressorHttp2ConnectionEncoder.writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endOfStream, ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writePing(ChannelHandlerContext ctx, boolean ack, long data, ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writePing(ChannelHandlerContext ctx, boolean ack, long data, ChannelPromise promise)
将PING帧写入远程端点。
|
ChannelFuture |
DefaultHttp2FrameWriter.writePing(ChannelHandlerContext ctx, boolean ack, long data, ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writePing(ChannelHandlerContext ctx, boolean ack, long data, ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writePing(ChannelHandlerContext ctx, boolean ack, long data, ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writePriority(ChannelHandlerContext ctx, int streamId, int streamDependency, short weight, boolean exclusive, ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writePriority(ChannelHandlerContext ctx, int streamId, int streamDependency, short weight, boolean exclusive, ChannelPromise promise)
将PRIORITY帧写入远程端点。
|
ChannelFuture |
DefaultHttp2FrameWriter.writePriority(ChannelHandlerContext ctx, int streamId, int streamDependency, short weight, boolean exclusive, ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writePriority(ChannelHandlerContext ctx, int streamId, int streamDependency, short weight, boolean exclusive, ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writePriority(ChannelHandlerContext ctx, int streamId, int streamDependency, short weight, boolean exclusive, ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writePushPromise(ChannelHandlerContext ctx, int streamId, int promisedStreamId, Http2Headers headers, int padding, ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writePushPromise(ChannelHandlerContext ctx, int streamId, int promisedStreamId, Http2Headers headers, int padding, ChannelPromise promise)
将PUSH_PROMISE帧写入远程端点。
|
ChannelFuture |
DefaultHttp2FrameWriter.writePushPromise(ChannelHandlerContext ctx, int streamId, int promisedStreamId, Http2Headers headers, int padding, ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writePushPromise(ChannelHandlerContext ctx, int streamId, int promisedStreamId, Http2Headers headers, int padding, ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writePushPromise(ChannelHandlerContext ctx, int streamId, int promisedStreamId, Http2Headers headers, int padding, ChannelPromise promise) |
ChannelFuture |
StreamBufferingEncoder.writeRstStream(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeRstStream(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writeRstStream(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise)
将RST_STREAM帧写入远程端点。
|
ChannelFuture |
DefaultHttp2FrameWriter.writeRstStream(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeRstStream(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writeRstStream(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeSettings(ChannelHandlerContext ctx, Http2Settings settings, ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writeSettings(ChannelHandlerContext ctx, Http2Settings settings, ChannelPromise promise)
将一个SETTINGS帧写入远程端点。
|
ChannelFuture |
DefaultHttp2FrameWriter.writeSettings(ChannelHandlerContext ctx, Http2Settings settings, ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeSettings(ChannelHandlerContext ctx, Http2Settings settings, ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writeSettings(ChannelHandlerContext ctx, Http2Settings settings, ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeSettingsAck(ChannelHandlerContext ctx, ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writeSettingsAck(ChannelHandlerContext ctx, ChannelPromise promise)
将SETTINGS确认写入远程端点。
|
ChannelFuture |
DefaultHttp2FrameWriter.writeSettingsAck(ChannelHandlerContext ctx, ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeSettingsAck(ChannelHandlerContext ctx, ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writeSettingsAck(ChannelHandlerContext ctx, ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeWindowUpdate(ChannelHandlerContext ctx, int streamId, int windowSizeIncrement, ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writeWindowUpdate(ChannelHandlerContext ctx, int streamId, int windowSizeIncrement, ChannelPromise promise)
将WINDOW_UPDATE帧写入远程端点。
|
ChannelFuture |
DefaultHttp2FrameWriter.writeWindowUpdate(ChannelHandlerContext ctx, int streamId, int windowSizeIncrement, ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeWindowUpdate(ChannelHandlerContext ctx, int streamId, int windowSizeIncrement, ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writeWindowUpdate(ChannelHandlerContext ctx, int streamId, int windowSizeIncrement, ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
void |
SpdyFrameCodec.bind(ChannelHandlerContext ctx, java.net.SocketAddress localAddress, ChannelPromise promise) |
void |
SpdySessionHandler.close(ChannelHandlerContext ctx, ChannelPromise promise) |
void |
SpdyFrameCodec.close(ChannelHandlerContext ctx, ChannelPromise promise) |
void |
SpdyFrameCodec.connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise) |
void |
SpdyFrameCodec.deregister(ChannelHandlerContext ctx, ChannelPromise promise) |
void |
SpdyFrameCodec.disconnect(ChannelHandlerContext ctx, ChannelPromise promise) |
void |
SpdySessionHandler.write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise) |
void |
SpdyFrameCodec.write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
void |
FlushConsolidationHandler.close(ChannelHandlerContext ctx, ChannelPromise promise) |
void |
FlushConsolidationHandler.disconnect(ChannelHandlerContext ctx, ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
void |
LoggingHandler.bind(ChannelHandlerContext ctx, java.net.SocketAddress localAddress, ChannelPromise promise) |
void |
LoggingHandler.close(ChannelHandlerContext ctx, ChannelPromise promise) |
void |
LoggingHandler.connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise) |
void |
LoggingHandler.deregister(ChannelHandlerContext ctx, ChannelPromise promise) |
void |
LoggingHandler.disconnect(ChannelHandlerContext ctx, ChannelPromise promise) |
void |
LoggingHandler.write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
void |
ProxyHandler.connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise) |
void |
ProxyHandler.write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
void |
SslHandler.bind(ChannelHandlerContext ctx, java.net.SocketAddress localAddress, ChannelPromise promise) |
void |
AbstractSniHandler.bind(ChannelHandlerContext ctx, java.net.SocketAddress localAddress, ChannelPromise promise) |
void |
SslHandler.close(ChannelHandlerContext ctx, ChannelPromise promise) |
void |
AbstractSniHandler.close(ChannelHandlerContext ctx, ChannelPromise promise) |
ChannelFuture |
SslHandler.close(ChannelPromise promise)
|
void |
SslHandler.connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise) |
void |
AbstractSniHandler.connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise) |
void |
SslHandler.deregister(ChannelHandlerContext ctx, ChannelPromise promise) |
void |
AbstractSniHandler.deregister(ChannelHandlerContext ctx, ChannelPromise promise) |
void |
SslHandler.disconnect(ChannelHandlerContext ctx, ChannelPromise promise) |
void |
AbstractSniHandler.disconnect(ChannelHandlerContext ctx, ChannelPromise promise) |
void |
SslHandler.write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise) |
void |
AbstractSniHandler.write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
void |
ChunkedWriteHandler.write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
void |
WriteTimeoutHandler.write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise) |
void |
IdleStateHandler.write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractTrafficShapingHandler.submitWrite(ChannelHandlerContext ctx, java.lang.Object msg, long delay, ChannelPromise promise)
已过时。
|
protected void |
GlobalChannelTrafficShapingHandler.submitWrite(ChannelHandlerContext ctx, java.lang.Object msg, long size, long writedelay, long now, ChannelPromise promise) |
void |
GlobalChannelTrafficShapingHandler.write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise) |
void |
AbstractTrafficShapingHandler.write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise) |
Copyright © 2008–2018 The Netty Project. All rights reserved.