diff --git a/test/parallel/test-http-agent-destroyed-socket.js b/test/parallel/test-http-agent-destroyed-socket.js index 34772f7d3e3081..6c714fa235a050 100644 --- a/test/parallel/test-http-agent-destroyed-socket.js +++ b/test/parallel/test-http-agent-destroyed-socket.js @@ -1,35 +1,35 @@ 'use strict'; -require('../common'); -var assert = require('assert'); -var http = require('http'); +const common = require('../common'); +const assert = require('assert'); +const http = require('http'); -var server = http.createServer(function(req, res) { +const server = http.createServer((req, res) => { res.writeHead(200, {'Content-Type': 'text/plain'}); res.end('Hello World\n'); }).listen(0, function() { - var agent = new http.Agent({maxSockets: 1}); + const agent = new http.Agent({maxSockets: 1}); - agent.on('free', function(socket, host, port) { + agent.on('free', (socket, host, port) => { console.log('freeing socket. destroyed? ', socket.destroyed); }); - var requestOptions = { + const requestOptions = { agent: agent, host: 'localhost', port: this.address().port, path: '/' }; - var request1 = http.get(requestOptions, function(response) { + const request1 = http.get(requestOptions, common.mustCall((response) => { // assert request2 is queued in the agent - var key = agent.getName(requestOptions); - assert(agent.requests[key].length === 1); + const key = agent.getName(requestOptions); + assert.strictEqual(agent.requests[key].length, 1); console.log('got response1'); - request1.socket.on('close', function() { + request1.socket.on('close', () => { console.log('request1 socket closed'); }); response.pipe(process.stdout); - response.on('end', function() { + response.on('end', () => { console.log('response1 done'); ///////////////////////////////// // @@ -44,43 +44,43 @@ var server = http.createServer(function(req, res) { // is triggered. request1.socket.destroy(); - response.once('close', function() { + response.once('close', common.mustCall(() => { // assert request2 was removed from the queue assert(!agent.requests[key]); console.log("waiting for request2.onSocket's nextTick"); - process.nextTick(function() { + process.nextTick(() => { // assert that the same socket was not assigned to request2, // since it was destroyed. - assert(request1.socket !== request2.socket); + assert.notStrictEqual(request1.socket, request2.socket); assert(!request2.socket.destroyed, 'the socket is destroyed'); }); - }); + })); }); - }); + })); - var request2 = http.get(requestOptions, function(response) { + const request2 = http.get(requestOptions, common.mustCall((response) => { assert(!request2.socket.destroyed); assert(request1.socket.destroyed); // assert not reusing the same socket, since it was destroyed. - assert(request1.socket !== request2.socket); + assert.notStrictEqual(request1.socket, request2.socket); console.log('got response2'); - var gotClose = false; - var gotResponseEnd = false; - request2.socket.on('close', function() { + let gotClose = false; + let gotResponseEnd = false; + request2.socket.on('close', common.mustCall(() => { console.log('request2 socket closed'); gotClose = true; done(); - }); + })); response.pipe(process.stdout); - response.on('end', function() { + response.on('end', common.mustCall(() => { console.log('response2 done'); gotResponseEnd = true; done(); - }); + })); function done() { if (gotResponseEnd && gotClose) server.close(); } - }); + })); });