Destroy socket if when no timeout listener is found

lib/server.js

@@ -13,11 +13,11 @@ module.exports = class HTTPServer extends TCPServer {
     this._timeout = 0
 
     this.on('connection', (socket) => {
-      new HTTPServerConnection(this, socket, opts)
+      const conn = new HTTPServerConnection(this, socket, opts)
 
       if (this._timeout) {
         socket.setTimeout(this._timeout)
-        socket.once('timeout', () => this.emit('timeout', socket))
+        socket.once('timeout', () => this._ontimeout(conn))
       }
     })
 
@@ -34,4 +34,12 @@ module.exports = class HTTPServer extends TCPServer {
 
     return this
   }
+
+  _ontimeout (conn) {
+    const reqTimeout = conn.req && conn.req.emit('timeout')
+    const resTimeout = conn.res && conn.res.emit('timeout')
+    const serverTimeout = this.emit('timeout', conn.socket)
+
+    if (!reqTimeout && !resTimeout && !serverTimeout) conn.socket.destroy()
+  }
 }

test.js

@@ -563,6 +563,40 @@ test('server timeout', async function (t) {
   server.close()
 })
 
+test('close the server at timeout if do not have any handler', async function (t) {
+  t.plan(1)
+  const server = http.createServer().listen(0).setTimeout(100)
+
+  await waitForServer(server)
+
+  const client = http.request({ port: server.address().port })
+
+  client.on('error', () => {
+    t.pass()
+
+    server.close()
+  })
+})
+
+test('do not close the server at timeout if a handler is found', async function (t) {
+  t.plan(1)
+
+  const server = http.createServer((req, res) => {
+    res.on('timeout', () => {
+      t.pass('response timeout')
+
+      res.end()
+      server.close()
+    })
+  })
+
+  server.listen(0).setTimeout(100)
+
+  await waitForServer(server)
+
+  http.request({ port: server.address().port }).end()
+})
+
 test('server response timeout', async function (t) {
   const sub = t.test()
   sub.plan(2)