Trap EMFILE on both read and write streams

davglass · Oct 5, 2012 · b960127 · b960127
1 parent 0d2bc35
commit b960127
Showing 1 changed file with 13 additions and 11 deletions.
diff --git a/lib/index.js b/lib/index.js
@@ -118,18 +118,20 @@ var createFiles = function(files, to, options, callback) {
         copy = function(from, to, callback) {
             var fromFile = fs.createReadStream(from),
                 toFile = fs.createWriteStream(to),
-                bail;
+                bail,
+                onError = function (err) {
+                    if (/EMFILE/.test(err)) {
+                        bail = true;
+                        setTimeout(function() {
+                            copy(from, to, callback);
+                        }, 50);
+                    } else if (err) {
+                        options.errors.push(err);
+                    }
+                };
 
-            fromFile.on('error', function (err) {
-                if (/EMFILE/.test(err)) {
-                    bail = true;
-                    setTimeout(function() {
-                        copy(from, to, callback);
-                    }, 50);
-                } else if (err) {
-                    options.errors.push(err);
-                }
-            });
+            fromFile.on('error', onError);
+            toFile.on('error', onError);
             fromFile.pipe(toFile);
             fromFile.once('end', function() {
                 if (!bail) {