@@ -153,6 +153,7 @@ BoostDownloader.prototype._downloadVersion = function (version) {
153153 return fs . mkdirpAsync ( internalPath )
154154 . then ( function ( ) {
155155 return new Bluebird ( function ( resolve , reject ) {
156+ gunzip . once ( "error" , function ( err ) { reject ( err ) ; } ) ;
156157 extracter . once ( "end" , function ( ) {
157158 self . log . verbose ( "BOOST" , "Downloaded: " + internalPath ) ;
158159 resolve ( ) ;
@@ -162,7 +163,9 @@ BoostDownloader.prototype._downloadVersion = function (version) {
162163 . get ( downloadUrl )
163164 . on ( "error" , function ( err ) { reject ( err ) ; } )
164165 . pipe ( gunzip )
165- . pipe ( extracter ) ;
166+ . on ( "error" , function ( err ) { reject ( err ) ; } )
167+ . pipe ( extracter )
168+ . on ( "error" , function ( err ) { reject ( err ) ; } ) ;
166169 } ) ;
167170 } )
168171 . then ( function ( ) {
@@ -203,8 +206,9 @@ BoostDownloader.prototype._downloadSubmodules = function (version, internalPath)
203206 else {
204207 self . log . verbose ( "BOOST" , ( ( done / libTasks . length ) * 100 ) . toFixed ( 1 ) + "% - submodule " + dirName + "/" + lib + " exists." ) ;
205208 }
206- } ,
207- function ( e ) {
209+ } )
210+ . catch ( function ( e ) {
211+ ++ done ;
208212 self . log . info ( "BOOST" , ( ( done / libTasks . length ) * 100 ) . toFixed ( 1 ) + "% - submodule " + dirName + "/" + lib + " download error." ) ;
209213 self . log . silly ( "BOOST" , "Error: " + e . stack ) ;
210214 } ) ) ;
@@ -242,6 +246,7 @@ BoostDownloader.prototype._downloadSubmo = function (version, internalPath, name
242246 } ) ;
243247
244248 return new Bluebird ( function ( resolve , reject ) {
249+ gunzip . once ( "error" , function ( err ) { reject ( err ) ; } ) ;
245250 extracter . once ( "end" , function ( ) {
246251 resolve ( internalPath ) ;
247252 } ) ;
@@ -250,7 +255,9 @@ BoostDownloader.prototype._downloadSubmo = function (version, internalPath, name
250255 . get ( downloadUrl )
251256 . on ( "error" , function ( err ) { reject ( err ) ; } )
252257 . pipe ( gunzip )
253- . pipe ( extracter ) ;
258+ . on ( "error" , function ( err ) { reject ( err ) ; } )
259+ . pipe ( extracter )
260+ . on ( "error" , function ( err ) { reject ( err ) ; } ) ;
254261 } ) ;
255262 } ) ;
256263} ;
0 commit comments