Added test that covers error inside async handler.

package.json

@@ -9,7 +9,7 @@
   },
   "scripts": {
     "lint": "standard | snazzy",
-    "unit": "tap \"test/*.js\"",
+    "unit": "tap --100 \"test/*.js\"",
     "test:js": "npm run lint && npm run unit",
     "test:ts": "tsd",
     "test": "npm run lint && npm run test:js && npm run test:ts"

test/router.js

@@ -433,3 +433,58 @@ test('Should expose fastify instance to websocket per-route handler', t => {
     })
   })
 })
+
+test('should call `destroy` when exception is thrown inside async handler', t => {
+  t.plan(2)
+  const fastify = Fastify()
+
+  t.tearDown(() => fastify.close())
+
+  fastify.register(fastifyWebsocket)
+  fastify.get('/ws', { websocket: true }, async function wsHandler (conn, req) {
+    conn.on('error', err => {
+      t.equal(err.message, 'something wrong')
+      t.end()
+    })
+    throw new Error('something wrong')
+  })
+
+  fastify.listen(0, err => {
+    t.error(err)
+    const ws = new WebSocket(
+      'ws://localhost:' + (fastify.server.address()).port + '/ws'
+    )
+    const client = WebSocket.createWebSocketStream(ws, { encoding: 'utf8' })
+
+    client.on('error', (_) => { })
+    t.tearDown(client.destroy.bind(client))
+  })
+})
+
+test('register a non websocket route', t => {
+  t.plan(2)
+  const fastify = Fastify()
+
+  t.tearDown(() => fastify.close())
+
+  fastify.register(fastifyWebsocket)
+  fastify.get('/ws', function handler (req, reply) {
+    reply.send({ hello: 'world' })
+  })
+
+  fastify.listen(0, err => {
+    t.error(err)
+    get('http://localhost:' + (fastify.server.address()).port + '/ws', function (response) {
+      let data = ''
+
+      response.on('data', (chunk) => {
+        data += chunk
+      })
+
+      response.on('end', () => {
+        t.equal(data, '{"hello":"world"}')
+        t.end()
+      })
+    })
+  })
+})