pingRequired method

bool pingRequired()

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;
}