fix: Fix http2-dispatcher test (#4640)

Author: mcollina

test/http2-dispatcher.js

@@ -23,6 +23,9 @@ test('Dispatcher#Stream', async t => {
     stream.on('data', chunk => {
       requestBody += chunk
     })
+    stream.on('error', err => {
+      t.fail(err)
+    })
 
     stream.respond({ ':status': 200, 'x-custom': 'custom-header' })
     stream.end('hello h2!')
@@ -74,6 +77,10 @@ test('Dispatcher#Pipeline', async t => {
       requestBody += chunk
     })
 
+    stream.on('error', err => {
+      t.fail(err)
+    })
+
     stream.respond({ ':status': 200, 'x-custom': 'custom-header' })
     stream.end('hello h2!')
   })
@@ -137,6 +144,10 @@ test('Dispatcher#Connect', async t => {
       return
     }
 
+    stream.on('error', err => {
+      t.fail(err)
+    })
+
     const forward = new Client(`https://localhost:${server.address().port}`, {
       connect: {
         rejectUnauthorized: false
@@ -156,7 +167,7 @@ test('Dispatcher#Connect', async t => {
       })
 
       stream.respond({ ':status': 200, 'x-my-header': response.headers['x-my-header'] })
-      pipeline(response.body, stream, () => {})
+      response.body.pipe(stream)
     } catch (err) {
       stream.destroy(err)
     }
@@ -171,6 +182,10 @@ test('Dispatcher#Connect', async t => {
       t.strictEqual(requestBody, expectedBody)
     })
 
+    stream.on('error', err => {
+      t.fail(err)
+    })
+
     stream.respond({ ':status': 200, 'x-my-header': headers['x-my-header'] })
     stream.end('helloworld')
   })
@@ -199,9 +214,7 @@ test('Dispatcher#Connect', async t => {
     t.strictEqual(responseBody, 'helloworld')
   })
   socket.setEncoding('utf-8')
-  socket.cork()
   socket.write(expectedBody)
-  socket.uncork()
   socket.end()
 
   await t.completed
@@ -213,6 +226,12 @@ test('Dispatcher#Upgrade', async t => {
   const server = createSecureServer(await pem.generate({ opts: { keySize: 2048 } }))
 
   server.on('stream', (stream, headers) => {
+    stream.on('error', err => {
+      t.fail(err)
+    })
+
+    stream.resume()
+
     stream.end()
   })
 
@@ -244,6 +263,10 @@ test('Dispatcher#destroy', async t => {
   const server = createSecureServer(await pem.generate({ opts: { keySize: 2048 } }))
 
   server.on('stream', (stream, headers) => {
+    stream.on('error', err => {
+      t.fail(err)
+    })
+    stream.resume()
     setTimeout(stream.end.bind(stream), 1500)
   })
 
@@ -329,6 +352,10 @@ test('Should handle h2 request without body', async t => {
       ':status': 200
     })
 
+    stream.on('error', err => {
+      t.fail(err)
+    })
+
     for await (const chunk of stream) {
       requestChunks.push(chunk)
     }