From beca4c609faf591f827f25678ee549230229b9d2 Mon Sep 17 00:00:00 2001
From: coderaiser <mnemonic.enemy@gmail.com>
Date: Fri, 4 Oct 2013 08:24:15 +0000
Subject: [PATCH] refactor(pipe) create: add ifExec

---
 lib/server/pipe.js | 11 ++++-------
 1 file changed, 4 insertions(+), 7 deletions(-)

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);
+            });
         }
     };