@@ -26,11 +26,6 @@ var writeFileSync = require( '@stdlib/fs/write-file' ).sync;
2626var unlinkSync = require ( '@stdlib/fs/unlink' ) . sync ;
2727var parallel = require ( './../lib' ) ;
2828
29- var nFiles = 100 ;
30- var files ;
31- var opts ;
32- var dir ;
33-
3429/**
3530* Returns a generated script.
3631*
@@ -84,33 +79,35 @@ function createScripts( dir, nFiles ) {
8479 var files ;
8580 var i ;
8681
87- files = new Array ( nFiles ) ;
82+ files = [ ] ;
8883 for ( i = 0 ; i < nFiles ; i ++ ) {
8984 content = template ( i . toString ( ) ) ;
9085 fpath = path . join ( dir , i + '.js' ) ;
9186 writeFileSync ( fpath , content , {
9287 'encoding' : 'utf8'
9388 } ) ;
94- files [ i ] = fpath ;
89+ files . push ( fpath ) ;
9590 }
9691 return files ;
9792}
9893
99- /**
100- * Performs clean-up tasks once all scripts have run.
101- *
102- * @private
103- */
104- function cleanup ( ) {
105- var i ;
94+ var nFiles = 10 ;
10695
107- // Delete the temporary files...
108- for ( i = 0 ; i < files . length ; i ++ ) {
109- unlinkSync ( files [ i ] ) ;
110- }
111- // Remove temporary directory:
112- fs . rmdirSync ( dir ) ;
113- }
96+ // Make a temporary directory to store files:
97+ var dir = createDir ( ) ;
98+
99+ // Create temporary files:
100+ var files = createScripts ( dir , nFiles ) ;
101+
102+ // Set the runner options:
103+ var opts = {
104+ 'concurrency' : 3 ,
105+ 'workers' : 3 ,
106+ 'ordered' : false
107+ } ;
108+
109+ // Run all temporary scripts:
110+ parallel ( files , opts , done ) ;
114111
115112/**
116113* Callback invoked once all scripts finish.
@@ -120,24 +117,24 @@ function cleanup() {
120117*/
121118function done ( error ) {
122119 if ( error ) {
123- throw error ;
120+ console . log ( error . message ) ;
124121 }
125122 cleanup ( ) ;
126123 console . log ( 'Done!' ) ;
127124}
128125
129- // Make a temporary directory to store files...
130- dir = createDir ( ) ;
131-
132- // Create temporary files...
133- files = createScripts ( dir , nFiles ) ;
134-
135- // Set the runner options:
136- opts = {
137- 'concurrency' : 3 ,
138- 'workers' : 3 ,
139- 'ordered' : false
140- } ;
126+ /**
127+ * Performs clean-up tasks once all scripts have run.
128+ *
129+ * @private
130+ */
131+ function cleanup ( ) {
132+ var i ;
141133
142- // Run all temporary scripts:
143- parallel ( files , opts , done ) ;
134+ // Delete the temporary files...
135+ for ( i = 0 ; i < files . length ; i ++ ) {
136+ unlinkSync ( files [ i ] ) ;
137+ }
138+ // Remove temporary directory:
139+ fs . rmdirSync ( dir ) ;
140+ }
0 commit comments