Package org.apache.pekko.http.impl.engine.http2

Class ConfigurablePing.EnabledPingState

java.lang.Object

org.apache.pekko.http.impl.engine.http2.ConfigurablePing.EnabledPingState

All Implemented Interfaces:

ConfigurablePing.PingState

Enclosing class:

ConfigurablePing

public static final class ConfigurablePing.EnabledPingState
extends Object
implements ConfigurablePing.PingState

Constructor Summary

Constructors

Constructor	Description
EnabledPingState(scala.concurrent.duration.FiniteDuration _tickInterval, long pingEveryNTickWithoutData)

Method Summary

Modifier and Type	Method	Description
void	clear()
void	onDataFrameSeen()
void	onPingAck()
void	onTick()
boolean	pingAckOverdue()
void	sendingPing()
boolean	shouldEmitPing()
scala.Option<scala.concurrent.duration.FiniteDuration>	tickInterval()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

EnabledPingState

public EnabledPingState(scala.concurrent.duration.FiniteDuration _tickInterval,
 long pingEveryNTickWithoutData)

Method Details

clear

public void clear()

Specified by:

clear in interface ConfigurablePing.PingState

onDataFrameSeen

public void onDataFrameSeen()

Specified by:

onDataFrameSeen in interface ConfigurablePing.PingState

onPingAck

public void onPingAck()

Specified by:

onPingAck in interface ConfigurablePing.PingState

onTick

public void onTick()

Specified by:

onTick in interface ConfigurablePing.PingState

pingAckOverdue

public boolean pingAckOverdue()

Specified by:

pingAckOverdue in interface ConfigurablePing.PingState

sendingPing

public void sendingPing()

Specified by:

sendingPing in interface ConfigurablePing.PingState

shouldEmitPing

public boolean shouldEmitPing()

Specified by:

shouldEmitPing in interface ConfigurablePing.PingState

tickInterval

public scala.Option<scala.concurrent.duration.FiniteDuration> tickInterval()

Specified by:

tickInterval in interface ConfigurablePing.PingState