fix: await close event in thread-management tests to prevent flakiness (#181)

Author: mcollina

test/thread-management.test.js

@@ -26,6 +26,8 @@ test('emit error if thread exits', async function (t) {
     sync: true
   })
 
+  const closed = once(stream, 'close').catch(() => {})
+
   stream.on('ready', () => {
     stream.write('hello world\n')
   })
@@ -40,6 +42,8 @@ test('emit error if thread exits', async function (t) {
   stream.write('noop');
   [err] = await once(stream, 'error')
   assert.strictEqual(err.message, 'the worker has exited')
+
+  await closed
 })
 
 test('emit error if thread have unhandledRejection', async function (t) {
@@ -48,6 +52,8 @@ test('emit error if thread have unhandledRejection', async function (t) {
     sync: true
   })
 
+  const closed = once(stream, 'close').catch(() => {})
+
   stream.on('ready', () => {
     stream.write('hello world\n')
   })
@@ -62,6 +68,8 @@ test('emit error if thread have unhandledRejection', async function (t) {
   stream.write('noop');
   [err] = await once(stream, 'error')
   assert.strictEqual(err.message, 'the worker has exited')
+
+  await closed
 })
 
 test('emit error if worker stream emit error', async function (t) {
@@ -70,6 +78,8 @@ test('emit error if worker stream emit error', async function (t) {
     sync: true
   })
 
+  const closed = once(stream, 'close').catch(() => {})
+
   stream.on('ready', () => {
     stream.write('hello world\n')
   })
@@ -84,6 +94,8 @@ test('emit error if worker stream emit error', async function (t) {
   stream.write('noop');
   [err] = await once(stream, 'error')
   assert.strictEqual(err.message, 'the worker has exited')
+
+  await closed
 })
 
 test('emit error if thread have uncaughtException', async function (t) {
@@ -92,6 +104,8 @@ test('emit error if thread have uncaughtException', async function (t) {
     sync: true
   })
 
+  const closed = once(stream, 'close').catch(() => {})
+
   stream.on('ready', () => {
     stream.write('hello world\n')
   })
@@ -106,6 +120,8 @@ test('emit error if thread have uncaughtException', async function (t) {
   stream.write('noop');
   [err] = await once(stream, 'error')
   assert.strictEqual(err.message, 'the worker has exited')
+
+  await closed
 })
 
 test('close the work if out of scope on gc', { skip: !global.WeakRef }, async function (t) {