@@ -1188,8 +1188,6 @@ var fileCompressed = function(path, _realPath = false) {
1188
1188
let _this = this ;
1189
1189
let only = this . config . only ;
1190
1190
1191
- let promises = [ ] ;
1192
-
1193
1191
for ( let i = 0 , len = zip . files . length ; i < len ; i ++ )
1194
1192
{
1195
1193
let entry = zip . files [ i ] ;
@@ -1216,20 +1214,18 @@ var fileCompressed = function(path, _realPath = false) {
1216
1214
1217
1215
this . setFileStatus ( name , { extracted : true } ) ;
1218
1216
1219
- promises . push ( new Promise ( function ( resolve , reject ) {
1217
+ await new Promise ( function ( resolve , reject ) {
1220
1218
entry . stream ( ) . pipe ( fs . createWriteStream ( path ) ) . on ( 'error' , reject ) . on ( 'finish' , function ( ) {
1221
1219
1222
1220
_this . setProgress ( _this . progressIndex ++ / len ) ;
1223
1221
_this . whenExtractFile ( virtualPath ) ;
1224
1222
1225
1223
resolve ( ) ;
1226
1224
} ) ;
1227
- } ) ) ;
1225
+ } ) ;
1228
1226
}
1229
1227
}
1230
1228
}
1231
-
1232
- await Promise . all ( promises ) ;
1233
1229
}
1234
1230
catch ( error )
1235
1231
{
@@ -1429,8 +1425,6 @@ var fileCompressed = function(path, _realPath = false) {
1429
1425
1430
1426
if ( ! error )
1431
1427
{
1432
- let promises = [ ] ;
1433
-
1434
1428
for ( let i = 0 , len = entries . length ; i < len ; i ++ )
1435
1429
{
1436
1430
let entry = entries [ i ] ;
@@ -1456,7 +1450,7 @@ var fileCompressed = function(path, _realPath = false) {
1456
1450
1457
1451
_this . setFileStatus ( name , { extracted : true } ) ;
1458
1452
1459
- promises . push ( new Promise ( function ( resolve , reject ) {
1453
+ await new Promise ( function ( resolve , reject ) {
1460
1454
rar . stream ( name ) . on ( 'error' , reject ) . on ( 'end' , function ( ) {
1461
1455
1462
1456
_this . setProgress ( _this . progressIndex ++ / len ) ;
@@ -1465,13 +1459,11 @@ var fileCompressed = function(path, _realPath = false) {
1465
1459
resolve ( ) ;
1466
1460
1467
1461
} ) . pipe ( fs . createWriteStream ( path ) ) ;
1468
- } ) ) ;
1462
+ } ) ;
1469
1463
}
1470
1464
}
1471
1465
}
1472
1466
1473
- await Promise . all ( promises ) ;
1474
-
1475
1467
_this . setProgress ( 1 ) ;
1476
1468
1477
1469
console . timeEnd ( 'extractRar' ) ;
0 commit comments