public static final class ConfigurablePing.EnabledPingState extends java.lang.Object implements ConfigurablePing.PingState
| Constructor and Description |
|---|
EnabledPingState(scala.concurrent.duration.FiniteDuration _tickInterval,
long pingEveryNTickWithoutData) |
| Modifier and Type | Method and Description |
|---|---|
void |
clear() |
void |
onDataFrameSeen() |
void |
onPingAck() |
void |
onTick() |
boolean |
pingAckOverdue() |
void |
sendingPing() |
boolean |
shouldEmitPing() |
scala.Option<scala.concurrent.duration.FiniteDuration> |
tickInterval() |
public EnabledPingState(scala.concurrent.duration.FiniteDuration _tickInterval,
long pingEveryNTickWithoutData)
public void clear()
clear in interface ConfigurablePing.PingStatepublic void onDataFrameSeen()
onDataFrameSeen in interface ConfigurablePing.PingStatepublic void onPingAck()
onPingAck in interface ConfigurablePing.PingStatepublic void onTick()
onTick in interface ConfigurablePing.PingStatepublic boolean pingAckOverdue()
pingAckOverdue in interface ConfigurablePing.PingStatepublic void sendingPing()
sendingPing in interface ConfigurablePing.PingStatepublic boolean shouldEmitPing()
shouldEmitPing in interface ConfigurablePing.PingStatepublic scala.Option<scala.concurrent.duration.FiniteDuration> tickInterval()
tickInterval in interface ConfigurablePing.PingState