more async

lib/core/fs.js

@@ -11,6 +11,10 @@ function mkdirp() {
   return fs.mkdirp.apply(fs.mkdirp, arguments);
 }
 
+function copy() {
+  return fs.copy.apply(fs.copy, arguments);
+}
+
 function copySync() {
   return fs.copySync.apply(fs.copySync, arguments);
 }
@@ -77,6 +81,7 @@ function createWriteStream() {
 module.exports = {
   mkdirpSync,
   mkdirp,
+  copy,
   copySync,
   readFile,
   readFileSync,

lib/pipeline/pipeline.js

@@ -185,28 +185,28 @@ class Pipeline {
                 targetDir = targetDir + '/';
               }
 
-              contentFiles.map(function (file) {
+              async.each(contentFiles, function (file, mapCb) {
                 let filename = file.filename.replace(file.basedir + '/', '');
                 self.log("writing file " + (self.buildDir + targetDir + filename).bold.dim);
 
-                fs.copySync(file.path, self.buildDir + targetDir + filename, {overwrite: true});
-              });
-            } else {
-              let content = contentFiles.map(function (file) {
-                if (file === undefined) {
-                  return "";
-                }
-                return file.content;
-              }).join("\n");
-
-              self.log("writing file " + (self.buildDir + targetFile).bold.dim);
-              fs.writeFileSync(self.buildDir + targetFile, content);
+                fs.copy(file.path, self.buildDir + targetDir + filename, {overwrite: true}, mapCb);
+              }, cb);
+              return;
             }
-            cb();
+
+            let content = contentFiles.map(function (file) {
+              if (file === undefined) {
+                return "";
+              }
+              return file.content;
+            }).join("\n");
+
+            self.log("writing file ASYNC " + (self.buildDir + targetFile).bold.dim);
+            fs.writeFile(self.buildDir + targetFile, content, cb);
           }
         );
       },
-        function (_err, _results) {
+        function (_err) {
           callback();
         });
     });