Manage err from stream

fshost · Aug 6, 2015 · 152269f · 152269f
1 parent d61da1b
commit 152269f
Showing 1 changed file with 3 additions and 9 deletions.
diff --git a/lib/readfilesstream.js b/lib/readfilesstream.js
@@ -102,19 +102,13 @@ function readFilesStream(dir, options, callback, complete) {
                     if (options.shortName) files.push(filename);
                     else files.push(file);
                     var stream = fs.createReadStream(file);
+                    stream.on('error',function(err) {
+                      return done(err);
+                    });
                     if (callback.length > 3)
                         if (options.shortName) callback(null, stream, filename, next);
                         else callback(null, stream, file, next);
                         else callback(null, stream, next);
-/*01
-                    fs.readFile(file, options.encoding, function(err, data) {
-                        if (err) return done(err);
-                        if (callback.length > 3)
-                            if (options.shortName) callback(null, data, filename, next);
-                            else callback(null, data, file, next);
-                            else callback(null, data, next);
-                    });
-*/
                 }
             });
         })();