io.netty.channel

类 PendingWriteQueue

java.lang.Object

io.netty.channel.PendingWriteQueue

public final class PendingWriteQueue
extends java.lang.Object

A queue of write operations which are pending for later execution. It also updates the writability of the associated Channel, so that the pending write operations are also considered to determine the writability.

构造器概要

构造器

构造器和说明
PendingWriteQueue(ChannelHandlerContext ctx)

方法概要

方法

限定符和类型	方法和说明
void	add(java.lang.Object msg, ChannelPromise promise) Add the given msg and ChannelPromise.
long	bytes() Returns the total number of bytes that are pending because of pending messages.
java.lang.Object	current() Return the current message or null if empty.
boolean	isEmpty() Returns true if there are no pending write operations left in this queue.
ChannelPromise	remove() Removes a pending write operation and release it's message via ReferenceCountUtil.safeRelease(Object).
void	removeAndFail(java.lang.Throwable cause) Remove a pending write operation and fail it with the given Throwable.
void	removeAndFailAll(java.lang.Throwable cause) Remove all pending write operation and fail them with the given Throwable.
ChannelFuture	removeAndWrite() Removes a pending write operation and performs it via ChannelHandlerContext.write(Object, ChannelPromise).
ChannelFuture	removeAndWriteAll() Remove all pending write operation and performs them via ChannelHandlerContext.write(Object, ChannelPromise).
int	size() Returns the number of pending write operations.

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

PendingWriteQueue

public PendingWriteQueue(ChannelHandlerContext ctx)

方法详细资料

isEmpty

public boolean isEmpty()

Returns true if there are no pending write operations left in this queue.

size

public int size()

Returns the number of pending write operations.

bytes

public long bytes()

Returns the total number of bytes that are pending because of pending messages. This is only an estimate so it should only be treated as a hint.

add

public void add(java.lang.Object msg,
       ChannelPromise promise)

Add the given msg and ChannelPromise.

removeAndWriteAll

public ChannelFuture removeAndWriteAll()

Remove all pending write operation and performs them via ChannelHandlerContext.write(Object, ChannelPromise).

返回:

ChannelFuture if something was written and null if the PendingWriteQueue is empty.

removeAndFailAll

public void removeAndFailAll(java.lang.Throwable cause)

Remove all pending write operation and fail them with the given Throwable. The message will be released via ReferenceCountUtil.safeRelease(Object).

removeAndFail

public void removeAndFail(java.lang.Throwable cause)

Remove a pending write operation and fail it with the given Throwable. The message will be released via ReferenceCountUtil.safeRelease(Object).

removeAndWrite

public ChannelFuture removeAndWrite()

Removes a pending write operation and performs it via ChannelHandlerContext.write(Object, ChannelPromise).

返回:

ChannelFuture if something was written and null if the PendingWriteQueue is empty.

remove

public ChannelPromise remove()

Removes a pending write operation and release it's message via ReferenceCountUtil.safeRelease(Object).

返回:

ChannelPromise of the pending write or null if the queue is empty.

current

public java.lang.Object current()

Return the current message or null if empty.