io.netty.channel

类 ChannelFlushPromiseNotifier

java.lang.Object

io.netty.channel.ChannelFlushPromiseNotifier

public final class ChannelFlushPromiseNotifier
extends java.lang.Object

This implementation allows to register ChannelFuture instances which will get notified once some amount of data was written and so a checkpoint was reached.

构造器概要

构造器

构造器和说明
ChannelFlushPromiseNotifier() Create a new instance which will use ChannelPromise.setSuccess() and ChannelPromise.setFailure(Throwable) to notify the ChannelPromises.
ChannelFlushPromiseNotifier(boolean tryNotify) Create a new instance

方法概要

限定符和类型	方法和说明
ChannelFlushPromiseNotifier	add(ChannelPromise promise, int pendingDataSize) 已过时。 use add(ChannelPromise, long)
ChannelFlushPromiseNotifier	add(ChannelPromise promise, long pendingDataSize) Add a ChannelPromise to this ChannelFlushPromiseNotifier which will be notified after the given pendingDataSize was reached.
ChannelFlushPromiseNotifier	increaseWriteCounter(long delta) Increase the current write counter by the given delta
ChannelFlushPromiseNotifier	notifyFlushFutures() 已过时。 use notifyPromises()
ChannelFlushPromiseNotifier	notifyFlushFutures(java.lang.Throwable cause) 已过时。 use notifyPromises(Throwable)
ChannelFlushPromiseNotifier	notifyFlushFutures(java.lang.Throwable cause1, java.lang.Throwable cause2) 已过时。 use notifyPromises(Throwable, Throwable)
ChannelFlushPromiseNotifier	notifyPromises() Notify all ChannelFutures that were registered with add(ChannelPromise, int) and their pendingDatasize is smaller after the current writeCounter returned by writeCounter().
ChannelFlushPromiseNotifier	notifyPromises(java.lang.Throwable cause) Notify all ChannelFutures that were registered with add(ChannelPromise, int) and their pendingDatasize isis smaller then the current writeCounter returned by writeCounter().
ChannelFlushPromiseNotifier	notifyPromises(java.lang.Throwable cause1, java.lang.Throwable cause2) Notify all ChannelFutures that were registered with add(ChannelPromise, int) and their pendingDatasize is smaller then the current writeCounter returned by writeCounter() using the given cause1.
long	writeCounter() Return the current write counter of this ChannelFlushPromiseNotifier

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

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

构造器详细资料

ChannelFlushPromiseNotifier

public ChannelFlushPromiseNotifier(boolean tryNotify)

Create a new instance

参数:

tryNotify - if true the ChannelPromises will get notified with ChannelPromise.trySuccess() and Promise.tryFailure(Throwable). Otherwise ChannelPromise.setSuccess() and ChannelPromise.setFailure(Throwable) is used

ChannelFlushPromiseNotifier

public ChannelFlushPromiseNotifier()

Create a new instance which will use ChannelPromise.setSuccess() and ChannelPromise.setFailure(Throwable) to notify the ChannelPromises.

方法详细资料

add

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

已过时。 use add(ChannelPromise, long)

add

public ChannelFlushPromiseNotifier add(ChannelPromise promise,
                                       long pendingDataSize)

Add a ChannelPromise to this ChannelFlushPromiseNotifier which will be notified after the given pendingDataSize was reached.

increaseWriteCounter

public ChannelFlushPromiseNotifier increaseWriteCounter(long delta)

Increase the current write counter by the given delta

writeCounter

public long writeCounter()

Return the current write counter of this ChannelFlushPromiseNotifier

notifyPromises

public ChannelFlushPromiseNotifier notifyPromises()

Notify all ChannelFutures that were registered with add(ChannelPromise, int) and their pendingDatasize is smaller after the current writeCounter returned by writeCounter(). After a ChannelFuture was notified it will be removed from this ChannelFlushPromiseNotifier and so not receive anymore notification.

notifyFlushFutures

@Deprecated
public ChannelFlushPromiseNotifier notifyFlushFutures()

已过时。 use notifyPromises()

notifyPromises

public ChannelFlushPromiseNotifier notifyPromises(java.lang.Throwable cause)

Notify all ChannelFutures that were registered with add(ChannelPromise, int) and their pendingDatasize isis smaller then the current writeCounter returned by writeCounter(). After a ChannelFuture was notified it will be removed from this ChannelFlushPromiseNotifier and so not receive anymore notification. The rest of the remaining ChannelFutures will be failed with the given Throwable. So after this operation this ChannelFutureListener is empty.

notifyFlushFutures

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

已过时。 use notifyPromises(Throwable)

notifyPromises

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

Notify all ChannelFutures that were registered with add(ChannelPromise, int) and their pendingDatasize is smaller then the current writeCounter returned by writeCounter() using the given cause1. After a ChannelFuture was notified it will be removed from this ChannelFlushPromiseNotifier and so not receive anymore notification. The rest of the remaining ChannelFutures will be failed with the given Throwable. So after this operation this ChannelFutureListener is empty.

参数:

cause1 - the Throwable which will be used to fail all of the ChannelFutures which pendingDataSize is smaller then the current writeCounter returned by writeCounter()

cause2 - the Throwable which will be used to fail the remaining ChannelFutures

notifyFlushFutures

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

已过时。 use notifyPromises(Throwable, Throwable)