fix test

gurgunday · Jul 5, 2024 · 2a81caa · 2a81caa
1 parent d196f1f
commit 2a81caa
Showing 1 changed file with 8 additions and 4 deletions.
diff --git a/test/consumer.test.js b/test/consumer.test.js
@@ -35,8 +35,10 @@ test('error event after connection', t => {
     t.error(err)
     consumer.consumer.emit('event.error', new Error('Test Error'))
   })
-  consumer.on('error', t.ok)
-  consumer.stop()
+  consumer.on('error', () => {
+    t.ok()
+    consumer.stop()
+  })
 })
 
 test('empty message with data event', t => {
@@ -46,6 +48,8 @@ test('empty message with data event', t => {
     t.error(err)
     t.throws(() => consumer.consumer.emit('data'))
   })
-  consumer.on('error', t.ok)
-  consumer.stop()
+  consumer.on('error', () => {
+    t.ok()
+    consumer.stop()
+  })
 })