diff --git a/lib/server/pipe.js b/lib/server/pipe.js
index 45e3ead1..c52ae9b8 100644
--- a/lib/server/pipe.js
+++ b/lib/server/pipe.js
@@ -45,15 +45,12 @@
             lWrite.on('error', lError);
             lRead.on('error', lError);
             
-            if (lIsFsWrite)
-                lWrite.on('open', function() {
-                    lRead.pipe(lWrite);
-                    lRead.on('end', Util.retExec(p.callback));
-                });
-            else {
+            Util.ifExec(!lIsFsWrite, function() {
                 lRead.pipe(lWrite);
                 lRead.on('end', Util.retExec(p.callback));
-            }
+            }, function(pCallBack) {
+                lWrite.on('open', pCallBack);
+            });
         }
     };