构造方法详细信息

• ChannelFlushPromiseNotifier

  public ChannelFlushPromiseNotifier(boolean tryNotify)

  创建一个新的实例

  参数

  tryNotify - 如果true ChannelPromise s将收到通知ChannelPromise.trySuccess()和Promise.tryFailure(Throwable) 。 否则使用ChannelPromise.setSuccess()和ChannelPromise.setFailure(Throwable)

• ChannelFlushPromiseNotifier

  public ChannelFlushPromiseNotifier()

  创建一个将使用ChannelPromise.setSuccess()和ChannelPromise.setFailure(Throwable)通知ChannelPromise的新实例。

方法详细信息

• add

  @Deprecated
  public ChannelFlushPromiseNotifier add(ChannelPromise promise,
                                                     int pendingDataSize)

  已过时。 使用add(ChannelPromise, long)

• add

  public ChannelFlushPromiseNotifier add(ChannelPromise promise,
                                         long pendingDataSize)

  将ChannelPromise添加到此ChannelFlushPromiseNotifier ，在达到给定的pendingDataSize后会通知您。

• increaseWriteCounter

  public ChannelFlushPromiseNotifier increaseWriteCounter(long delta)

  按给定的增量增加当前的写计数器

• writeCounter

  public long writeCounter()

  返回此ChannelFlushPromiseNotifier的当前写入计数器

• notifyPromises

  public ChannelFlushPromiseNotifier notifyPromises()

  通知所有ChannelFuture s已注册add(ChannelPromise, int)，并且在当前writeCounter返回writeCounter()之后，其pendingDatasize更小。 在通知ChannelFuture之后，它将从此ChannelFlushPromiseNotifier中删除，因此不会再收到通知。

• notifyFlushFutures

  @Deprecated
  public ChannelFlushPromiseNotifier notifyFlushFutures()

  已过时。 使用notifyPromises()

• notifyPromises

  public ChannelFlushPromiseNotifier notifyPromises(java.lang.Throwable cause)

  通知所有ChannelFuture s已注册add(ChannelPromise, int)，并且其pendingDatasize isis小于当前writeCounter返回的writeCounter() 。 在通知ChannelFuture后，它将从此ChannelFlushPromiseNotifier中删除，因此不会再收到通知。 其余的ChannelFuture s将会以给定的Throwable失败。 所以在这个操作之后，这个ChannelFutureListener是空的。

• notifyFlushFutures

  @Deprecated
  public ChannelFlushPromiseNotifier notifyFlushFutures(java.lang.Throwable cause)

  已过时。 使用notifyPromises(Throwable)

• notifyPromises

  public ChannelFlushPromiseNotifier notifyPromises(java.lang.Throwable cause1,
                                                    java.lang.Throwable cause2)

  通知所有ChannelFuture个认为登记与S add(ChannelPromise, int)及其pendingDatasize较小然后返回当前writeCounter writeCounter()使用给定的原因1。 在通知ChannelFuture后，它将从此ChannelFlushPromiseNotifier中删除，因此不会再收到通知。 剩余的ChannelFuture的其余部分将以给定的Throwable失败。 所以在这个操作之后，这个ChannelFutureListener是空的。

  参数

  cause1 - Throwable将用于使所有ChannelFuture失败，其中pendingDataSize小于writeCounter()返回的当前writeCounter

  cause2 - Throwable将用于使剩余的ChannelFuture失败

• notifyFlushFutures

  @Deprecated
  public ChannelFlushPromiseNotifier notifyFlushFutures(java.lang.Throwable cause1,
                                                                    java.lang.Throwable cause2)

  已过时。 使用notifyPromises(Throwable, Throwable)