pingRequired method
Pings the message broker if there has been no activity for the specified amount of idle time.
Implementation
bool pingRequired() {
if (_shutdownPadlock) {
return false;
} else {
_shutdownPadlock = true;
}
var pinged = false;
final pingMsg = MqttPingRequestMessage();
if (_connectionHandler.connectionStatus.state ==
MqttConnectionState.connected) {
_connectionHandler.sendMessage(pingMsg);
pinged = true;
}
pingTimer = Timer(Duration(milliseconds: keepAlivePeriod), pingRequired);
_shutdownPadlock = false;
return pinged;
}