diff --git a/test/regr-21.js b/test/regr-21.js
index a91fb000..a6e00b60 100644
--- 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)
 })