fixed tests broken by mqtt@4.0.0

moscajs · Apr 29, 2020 · 479fe85 · 479fe85
1 parent 8e40a23
commit 479fe85
Showing 1 changed file with 8 additions and 4 deletions.
diff --git a/test/not-blocking.js b/test/not-blocking.js
@@ -97,8 +97,10 @@ test('do not block after a subscription', function (t) {
         port: port,
         keepalive: 0
       }).on('error', function (err) {
-        clock.clearTimeout(clockId)
-        t.fail(err)
+        if (err.code !== 'ECONNRESET') {
+          clock.clearTimeout(clockId)
+          t.fail(err)
+        }
       })
 
       subscriber.subscribe('test', publish)
@@ -172,8 +174,10 @@ test('do not block with overlapping subscription', function (t) {
         port: port,
         keepalive: 0
       }).on('error', function (err) {
-        clock.clearTimeout(clockId)
-        t.fail(err)
+        if (err.code !== 'ECONNRESET') {
+          clock.clearTimeout(clockId)
+          t.fail(err)
+        }
       })
 
       subscriber.subscribe('#', function () {