构造方法详细信息

• PendingWriteQueue

  public PendingWriteQueue(ChannelHandlerContext ctx)

方法详细信息

• isEmpty

  public boolean isEmpty()

  如果此队列中没有未完成的写入操作，则返回 true 。

• size

  public int size()

  返回未决写入操作的数量。

• bytes

  public long bytes()

  返回由于未决消息而处于未决状态的总字节数。 这只是一个估计，所以它只应被视为一个提示。

• add

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

  添加给定的msg和ChannelPromise 。

• removeAndWriteAll

  public ChannelFuture removeAndWriteAll()

  删除所有待处理的写入操作并通过 ChannelOutboundInvoker.write(Object, ChannelPromise)执行它们。

  结果

  ChannelFuture如果写了内容， null如果PendingWriteQueue为空。

• removeAndFailAll

  public void removeAndFailAll(java.lang.Throwable cause)

  删除所有待处理的写入操作，并使用给定的Throwable使它们Throwable 。 该消息将通过ReferenceCountUtil.safeRelease(Object)发布。

• removeAndFail

  public void removeAndFail(java.lang.Throwable cause)

  删除待执行的写入操作，并使用给定的Throwable使其失败。 该消息将通过ReferenceCountUtil.safeRelease(Object)发布。

• removeAndWrite

  public ChannelFuture removeAndWrite()

  删除待执行的写入操作并通过 ChannelOutboundInvoker.write(Object, ChannelPromise)执行。

  结果

  ChannelFuture如果写了内容， null如果PendingWriteQueue是空的。

• remove

  public ChannelPromise remove()

  通过 ReferenceCountUtil.safeRelease(Object)删除挂起的写入操作并释放它的消息。

  结果

  ChannelPromise挂起的写的或null如果队列是空的。

• current

  public java.lang.Object current()

  如果为空，则返回当前消息或 null 。