构造方法详细信息

• AbstractCoalescingBufferQueue

  protected AbstractCoalescingBufferQueue(Channel channel,
                                          int initSize)

  创建一个新的实例。

  参数

  channel -所述Channel ，其将具有Channel.isWritable()反映排队缓冲器的量或null如果更新没有可写状态。

  initSize - 基础队列的初始大小。

方法详细信息

• addFirst

  public final void addFirst(ByteBuf buf,
                             ChannelPromise promise)

  将一个缓冲区添加到队列的前面，并将一个承诺与它关联起来，当所有缓冲区的字节已从队列中消耗并写入时应该完成该承诺。

  参数

  buf - 添加到队列的头部

  promise - 当所有字节被消耗和写入时完成，可以是无效的。

• add

  public final void add(ByteBuf buf)

  在队列的末尾添加一个缓冲区。

• add

  public final void add(ByteBuf buf,
                        ChannelPromise promise)

  将一个缓冲区添加到队列的末尾，并将一个承诺与它关联起来，当所有缓冲区的字节已从队列中消耗并写入时应该完成该承诺。

  参数

  buf - 添加到队列尾部

  promise - 在所有字节被消耗和写入时完成，可以是无效的。

• add

  public final void add(ByteBuf buf,
                        ChannelFutureListener listener)

  将一个缓冲区添加到队列的末尾，并将一个侦听器与它关联起来，当所有缓冲区字节已从队列中消耗并写入时应该完成侦听器。

  参数

  buf - 添加到队列尾部

  listener - 通知所有字节已被使用和写入时，可以是 null 。

• removeFirst

  public final ByteBuf removeFirst(ChannelPromise aggregatePromise)

  从队列中移除第一个ByteBuf 。

  参数

  aggregatePromise - 用于聚合返回缓冲区的承诺和侦听器。

  结果

  队列中的第一个ByteBuf 。

• remove

  public final ByteBuf remove(ByteBufAllocator alloc,
                              int bytes,
                              ChannelPromise aggregatePromise)

  从指定字节数的队列中删除ByteBuf 。 任何添加的字节缓冲区在删除过程中会被完全消耗，当传递的聚合ChannelPromise完成时，它将承诺完成。

  参数

  alloc - 如果在聚合过程中生成新的ByteBuf，则使用分配器。

  bytes -返回可读的最大字节数ByteBuf ，如果bytes大于readableBytes接着长度的缓冲器readableBytes被返回。

  aggregatePromise - 用于聚合组成缓冲区的承诺和侦听器。

  结果

  一个由入队缓冲区组成的ByteBuf 。

• readableBytes

  public final int readableBytes()

  可读字节数。

• isEmpty

  public final boolean isEmpty()

  队列中是否有挂起的缓冲区。

• releaseAndFailAll

  public final void releaseAndFailAll(ChannelOutboundInvoker invoker,
                                      java.lang.Throwable cause)

  释放队列中的所有缓冲区并完成所有侦听器和承诺。

• copyTo

  public final void copyTo(AbstractCoalescingBufferQueue dest)

  将此队列中的所有待处理条目复制到目标队列中。

  参数

  dest - 将待处理的缓冲区复制到。

• writeAndRemoveAll

  public final void writeAndRemoveAll(ChannelHandlerContext ctx)

  将所有剩余的元素写入此队列中。

  参数

  ctx - 将所有元素写入的上下文。

• compose

  protected abstract ByteBuf compose(ByteBufAllocator alloc,
                                     ByteBuf cumulation,
                                     ByteBuf next)

  计算 current + next的结果。

• composeIntoComposite

  protected final ByteBuf composeIntoComposite(ByteBufAllocator alloc,
                                               ByteBuf cumulation,
                                               ByteBuf next)

  将cumulation和next成一个新的CompositeByteBuf 。

• copyAndCompose

  protected final ByteBuf copyAndCompose(ByteBufAllocator alloc,
                                         ByteBuf cumulation,
                                         ByteBuf next)

  将 cumulation和 next成新的 ByteBufAllocator.ioBuffer() 。

  参数

  alloc - 用于分配新缓冲区的分配器。

  cumulation - 当前累计。

  next - 下一个缓冲区。

  结果

  cumulation + next的结果。

• composeFirst

  protected ByteBuf composeFirst(ByteBufAllocator allocator,
                                 ByteBuf first)

  计算第一个ByteBuf ，随后调用compose(ByteBufAllocator, ByteBuf, ByteBuf) 。

• removeEmptyValue

  protected abstract ByteBuf removeEmptyValue()

  remove(ByteBufAllocator, int, ChannelPromise)被调用但队列为空时返回的值。

  结果

  代表一个空队列的ByteBuf 。

• size

  protected final int size()

  获取通过 add(ByteBuf)方法之一添加的此队列中元素的数量。

  结果

  此队列中元素的数量。