|
1 | 1 | 'use strict'; |
2 | | -require('../common'); |
3 | | -var assert = require('assert'); |
4 | | -var http = require('http'); |
| 2 | +const common = require('../common'); |
| 3 | +const assert = require('assert'); |
| 4 | +const http = require('http'); |
5 | 5 |
|
6 | | -var body = 'hello world\n'; |
| 6 | +const server = http.createServer(common.mustCall((req, res) => { |
| 7 | + const body = 'hello world\n'; |
7 | 8 |
|
8 | | -var server = http.createServer(function(req, res) { |
9 | 9 | res.writeHead(200, {'Content-Length': body.length}); |
10 | 10 | res.write(body); |
11 | 11 | res.end(); |
12 | | -}); |
| 12 | +}, 3)); |
13 | 13 |
|
14 | | -var agent = new http.Agent({maxSockets: 1}); |
15 | | -var headers = {'connection': 'keep-alive'}; |
16 | | -var name; |
| 14 | +const agent = new http.Agent({maxSockets: 1}); |
| 15 | +const headers = {'connection': 'keep-alive'}; |
| 16 | +let name; |
17 | 17 |
|
18 | | -server.listen(0, function() { |
| 18 | +server.listen(0, common.mustCall(function() { |
19 | 19 | name = agent.getName({ port: this.address().port }); |
20 | 20 | http.get({ |
21 | 21 | path: '/', headers: headers, port: this.address().port, agent: agent |
22 | | - }, function(response) { |
23 | | - assert.equal(agent.sockets[name].length, 1); |
24 | | - assert.equal(agent.requests[name].length, 2); |
| 22 | + }, common.mustCall((response) => { |
| 23 | + assert.strictEqual(agent.sockets[name].length, 1); |
| 24 | + assert.strictEqual(agent.requests[name].length, 2); |
25 | 25 | response.resume(); |
26 | | - }); |
| 26 | + })); |
27 | 27 |
|
28 | 28 | http.get({ |
29 | 29 | path: '/', headers: headers, port: this.address().port, agent: agent |
30 | | - }, function(response) { |
31 | | - assert.equal(agent.sockets[name].length, 1); |
32 | | - assert.equal(agent.requests[name].length, 1); |
| 30 | + }, common.mustCall((response) => { |
| 31 | + assert.strictEqual(agent.sockets[name].length, 1); |
| 32 | + assert.strictEqual(agent.requests[name].length, 1); |
33 | 33 | response.resume(); |
34 | | - }); |
| 34 | + })); |
35 | 35 |
|
36 | 36 | http.get({ |
37 | 37 | path: '/', headers: headers, port: this.address().port, agent: agent |
38 | | - }, function(response) { |
39 | | - response.on('end', function() { |
40 | | - assert.equal(agent.sockets[name].length, 1); |
| 38 | + }, common.mustCall((response) => { |
| 39 | + response.on('end', common.mustCall(() => { |
| 40 | + assert.strictEqual(agent.sockets[name].length, 1); |
41 | 41 | assert(!agent.requests.hasOwnProperty(name)); |
42 | 42 | server.close(); |
43 | | - }); |
| 43 | + })); |
44 | 44 | response.resume(); |
45 | | - }); |
46 | | -}); |
| 45 | + })); |
| 46 | +})); |
47 | 47 |
|
48 | | -process.on('exit', function() { |
| 48 | +process.on('exit', () => { |
49 | 49 | assert(!agent.sockets.hasOwnProperty(name)); |
50 | 50 | assert(!agent.requests.hasOwnProperty(name)); |
51 | 51 | }); |
0 commit comments