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.FlushCheckpoint
public void flushCheckpoint(long checkpoint)
flushCheckpoint
in interface ChannelFlushPromiseNotifier.FlushCheckpoint
public ChannelPromise promise()
promise
in interface ChannelFlushPromiseNotifier.FlushCheckpoint