private static class ChannelFlushPromiseNotifier.DefaultFlushCheckpoint extends java.lang.Object implements ChannelFlushPromiseNotifier.FlushCheckpoint
| Modifier and Type | Field and Description |
|---|---|
private long |
checkpoint |
private ChannelPromise |
future |
| Constructor and Description |
|---|
DefaultFlushCheckpoint(long checkpoint,
ChannelPromise future) |
| Modifier and Type | Method and Description |
|---|---|
long |
flushCheckpoint() |
void |
flushCheckpoint(long checkpoint) |
ChannelPromise |
promise() |
private long checkpoint
private final ChannelPromise future
DefaultFlushCheckpoint(long checkpoint,
ChannelPromise future)
public long flushCheckpoint()
flushCheckpoint in interface ChannelFlushPromiseNotifier.FlushCheckpointpublic void flushCheckpoint(long checkpoint)
flushCheckpoint in interface ChannelFlushPromiseNotifier.FlushCheckpointpublic ChannelPromise promise()
promise in interface ChannelFlushPromiseNotifier.FlushCheckpoint