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.PingState
public void onDataFrameSeen()
onDataFrameSeen
in interface ConfigurablePing.PingState
public void onPingAck()
onPingAck
in interface ConfigurablePing.PingState
public void onTick()
onTick
in interface ConfigurablePing.PingState
public boolean pingAckOverdue()
pingAckOverdue
in interface ConfigurablePing.PingState
public void sendingPing()
sendingPing
in interface ConfigurablePing.PingState
public boolean shouldEmitPing()
shouldEmitPing
in interface ConfigurablePing.PingState
public scala.Option<scala.concurrent.duration.FiniteDuration> tickInterval()
tickInterval
in interface ConfigurablePing.PingState