From 6bf07800a05cdccefb5c355d457f21e8a8a47cc6 Mon Sep 17 00:00:00 2001
From: James M Snell <jasnell@gmail.com>
Date: Tue, 4 Feb 2020 11:16:09 -0800
Subject: [PATCH] quic: fixup up test

---
 ...quic-client-connect-multiple-sequential.js | 20 ++++++++++++-------
 1 file changed, 13 insertions(+), 7 deletions(-)

diff --git a/test/parallel/test-quic-client-connect-multiple-sequential.js b/test/parallel/test-quic-client-connect-multiple-sequential.js
index f8f6d72ebc..4c60d13b64 100644
--- a/test/parallel/test-quic-client-connect-multiple-sequential.js
+++ b/test/parallel/test-quic-client-connect-multiple-sequential.js
@@ -38,22 +38,28 @@ const { once } = require('events');
 
   const client = quic.createSocket({ client: { key, cert, ca, alpn: 'meow' } });
 
+  const reqs = [];
   for (const server of servers) {
     const req = client.connect({
       address: 'localhost',
       port: server.endpoints[0].address.port
     });
 
-    const [ stream ] = await once(req, 'stream');
-    stream.resume();
-    await once(stream, 'end');
-
-    server.close();
-    req.close();
-    await once(req, 'close');
+    req.on('stream', common.mustCall((stream) => {
+      stream.resume();
+      stream.on('close', common.mustCall(() => {
+        req.close();
+      }));
+    }));
+    reqs.push(once(req, 'close'));
   }
+  await Promise.all(reqs);
 
   client.close();
 
   await once(client, 'close');
+  for (const server of servers)
+    server.close();
+
+  await Promise.all(servers.map((server) => once(server, 'close')));
 })().then(common.mustCall());