|
1 | 1 | 'use strict'; |
2 | | -require('../common'); |
3 | | -varassert=require('assert'); |
4 | | -varhttp=require('http'); |
| 2 | +constcommon=require('../common'); |
| 3 | +constassert=require('assert'); |
| 4 | +consthttp=require('http'); |
5 | 5 |
|
6 | | -varbody='hello world\n'; |
| 6 | +constserver=http.createServer(common.mustCall((req,res)=>{ |
| 7 | +constbody='hello world\n'; |
7 | 8 |
|
8 | | -varserver=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 | | -varagent=newhttp.Agent({maxSockets: 1}); |
15 | | -varheaders={'connection': 'keep-alive'}; |
16 | | -varname; |
| 14 | +constagent=newhttp.Agent({maxSockets: 1}); |
| 15 | +constheaders={'connection': 'keep-alive'}; |
| 16 | +letname; |
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