test: update test/parallel/test-http-pipe-fs.js to use countdown

PR-URL: #17346 Reviewed-By: Jon Moss <[email protected]> Reviewed-By: Anna Henningsen <[email protected]>

Author: chungngoops

test/parallel/test-http-pipe-fs.js

@@ -24,6 +24,10 @@ const common = require('../common');
 consthttp=require('http');
 constfs=require('fs');
 constpath=require('path');
+constCountdown=require('../common/countdown');
+constNUMBER_OF_STREAMS=2;
+
+constcountdown=newCountdown(NUMBER_OF_STREAMS,()=>server.close());
 
 common.refreshTmpDir();
 
@@ -39,27 +43,23 @@ const server = http.createServer(common.mustCall(function(req, res){
 },2)).listen(0,function(){
 http.globalAgent.maxSockets=1;
 
-for(leti=0;i<2;++i){
-(function(i){
-constreq=http.request({
-port: server.address().port,
-method: 'POST',
-headers: {
-'Content-Length': 5
-}
-},function(res){
-res.on('end',function(){
-console.error(`res${i} end`);
-if(i===2){
-server.close();
-}
-});
-res.resume();
-});
-req.on('socket',function(s){
-console.error(`req${i} start`);
+for(leti=0;i<NUMBER_OF_STREAMS;++i){
+constreq=http.request({
+port: server.address().port,
+method: 'POST',
+headers: {
+'Content-Length': 5
+}
+},function(res){
+res.on('end',function(){
+console.error(`res${i+1} end`);
+countdown.dec();
 });
-req.end('12345');
-}(i+1));
+res.resume();
+});
+req.on('socket',function(s){
+console.error(`req${i+1} start`);
+});
+req.end('12345');
 }
 });