Package | Description |
---|---|
io.netty.channel |
The core channel API which is asynchronous and event-driven abstraction of
various transports such as a
NIO Channel.
|
Modifier and Type | Method and Description |
---|---|
ChannelFlushPromiseNotifier |
ChannelFlushPromiseNotifier.add(ChannelPromise promise,
long pendingDataSize)
Add a
ChannelPromise to this ChannelFlushPromiseNotifier which will be notified after the given
pendingDataSize was reached. |
ChannelFlushPromiseNotifier |
ChannelFlushPromiseNotifier.increaseWriteCounter(long delta)
Increase the current write counter by the given delta
|
ChannelFlushPromiseNotifier |
ChannelFlushPromiseNotifier.notifyFlushFutures(Throwable cause1,
Throwable cause2)
Deprecated.
|
ChannelFlushPromiseNotifier |
ChannelFlushPromiseNotifier.notifyPromises()
Notify all
ChannelFuture s that were registered with add(ChannelPromise, long) and
their pendingDatasize is smaller after the the current writeCounter returned by writeCounter() . |
ChannelFlushPromiseNotifier |
ChannelFlushPromiseNotifier.notifyPromises(Throwable cause)
Notify all
ChannelFuture s that were registered with add(ChannelPromise, long) and
their pendingDatasize isis smaller then the current writeCounter returned by writeCounter() . |
ChannelFlushPromiseNotifier |
ChannelFlushPromiseNotifier.notifyPromises(Throwable cause1,
Throwable cause2)
Notify all
ChannelFuture s that were registered with add(ChannelPromise, long) and
their pendingDatasize is smaller then the current writeCounter returned by writeCounter() using
the given cause1. |
Copyright © 2008–2015 The Netty Project. All rights reserved.