If our pinger fails to receive a response, properly disconnect

src/Client.js

@@ -118,7 +118,7 @@ export default class Client extends EventEmitter {
    * @param {string} [userName] - Authentication username for this connection.
    * @param {string} [password] - Authentication password for this connection.
    * @param {Message} [willMessage] - sent by the server when the client disconnects abnormally.
-   * @param {number} [keepAliveInterval=60] - ping the server every n ms to avoid being disconnected by the remote end.
+   * @param {number} [keepAliveInterval=60] - ping the server every n seconds to avoid being disconnected by the remote end.
    * @param {number} [mqttVersion=4] - protocol version to use (3 or 4).
    * @param {boolean} [cleanSession=true] - if true the client and server persistent state is deleted on successful connect.
    */

src/ClientImplementation.js

@@ -624,6 +624,7 @@ class ClientImplementation {
 
         case MESSAGE_TYPE.PINGRESP:
           // We don't care whether the server is still there (yet)
+          this.sendPinger && this.sendPinger.reset();
           break;
 
         case MESSAGE_TYPE.DISCONNECT:

src/Pinger.js

@@ -1,7 +1,8 @@
 /** @flow */
 
 import WireMessage from './WireMessage';
-import { MESSAGE_TYPE } from './constants';
+import { ERROR, MESSAGE_TYPE } from './constants';
+import { format } from './util';
 import ClientImplementation from './ClientImplementation';
 
 /**
@@ -11,6 +12,7 @@ import ClientImplementation from './ClientImplementation';
 export default class {
   _client: ClientImplementation;
   _keepAliveIntervalMs: number;
+  isReset: boolean = false;
   pingReq: ArrayBuffer = new WireMessage(MESSAGE_TYPE.PINGREQ).encode();
   timeout: ?number;
 
@@ -21,12 +23,19 @@ export default class {
   }
 
   _doPing() {
-    this._client._trace('Pinger.doPing', 'send PINGREQ');
-    this._client.socket && this._client.socket.send(this.pingReq);
-    this.timeout = setTimeout(() => this._doPing(), this._keepAliveIntervalMs);
+    if (!this.isReset) {
+      this._client._trace('Pinger.doPing', 'Timed out');
+      this._client._disconnected(ERROR.PING_TIMEOUT.code, format(ERROR.PING_TIMEOUT));
+    } else {
+      this.isReset = false;
+      this._client._trace('Pinger.doPing', 'send PINGREQ');
+      this._client.socket && this._client.socket.send(this.pingReq);
+      this.timeout = setTimeout(() => this._doPing(), this._keepAliveIntervalMs);
+    }
   }
 
   reset() {
+    this.isReset = true;
     if (this.timeout) {
       clearTimeout(this.timeout);
       this.timeout = null;