public final class PendingWriteQueue
extends java.lang.Object

• Constructor Summary

  Constructors

  Constructor and Description
  PendingWriteQueue (ChannelHandlerContext ctx)

• Method Summary

  All Methods

  Modifier and Type	Method and Description
  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.

  • Methods inherited from class java.lang.Object

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

• Constructor Detail

  • PendingWriteQueue

    public PendingWriteQueue(ChannelHandlerContext ctx)

• Method Detail

  • 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).

    Returns:

    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).

    Returns:

    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).

    Returns:

    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.