diff --git a/lib/server/pipe.js b/lib/server/pipe.js
index c509857443..3954c11b19 100644
--- a/lib/server/pipe.js
+++ b/lib/server/pipe.js
@@ -31,8 +31,9 @@
         
         Util.exec.if(!isFSWrite, function() {
             pipe(streams, options, callback);
-        }, function(callback) {
-            write.on('open', callback);
+        }, function(fn) {
+            write.on('open', fn)
+                 .on('error', callback);
         });
     }