Merge 2cee5d1 into abcecd3

moscajs · Jul 20, 2019 · 952be1a · 952be1a
2 parents abcecd3 + 2cee5d1
commit 952be1a
Showing 1 changed file with 7 additions and 6 deletions.
diff --git a/test/regr-21.js b/test/regr-21.js
@@ -19,14 +19,15 @@ test('after an error, outstanding packets are discarded', function (t) {
   s.broker.mq.on('hello', function (msg, cb) {
     t.pass('first msg received')
     s.inStream.destroy(new Error('something went wrong'))
-    setImmediate(cb)
-  })
-
-  process.nextTick(function () {
-    s.inStream.write(packet)
-    setImmediate(function () {
+    cb()
+    setImmediate(() => {
+      packet.topic = 'foo'
       s.inStream.write(packet)
       s.inStream.write(packet)
     })
   })
+  s.broker.mq.on('foo', function (msg, cb) {
+    t.fail('msg received')
+  })
+  s.inStream.write(packet)
 })