Add reconnect method and test.

Add reconnect method. Add new test using reconnect method.
mqttjs · Feb 3, 2020 · 685ac95 · 685ac95
1 parent dbc0573
commit 685ac95
Show file tree

Hide file tree

Showing 2 changed files with 24 additions and 0 deletions.
diff --git a/index.js b/index.js
@@ -61,6 +61,10 @@ class AsyncClient {
     })
   }
 
+  reconnect (...args) {
+    return this._client.reconnect(...args);
+  }
+
   addListener (...args) {
     return this._client.addListener(...args);
   }

diff --git a/test.js b/test.js
@@ -131,6 +131,26 @@ function runTests () {
       return client.end();
     });
   });
+
+  test('Calling reconnect after end should resolve once reconnect', t => {
+    t.plan(2);
+
+    const client = AsyncMQTT.connect(SERVER_URL);
+
+    client.once('reconnect', () => {
+      t.pass('Reconnect event occured');
+      client.once('connect', () => {
+        client.end();
+      });
+    });
+
+    client.once('connect', () => {
+      client.end().then(() => {
+        t.pass('End resolved');
+        client.reconnect();
+      });
+    });
+  });
 }
 
 // Taken from MQTT.js tests