From d9957c52d742c46929d7e1105dc3480f1911b5ef Mon Sep 17 00:00:00 2001
From: coderaiser <mnemonic.enemy@gmail.com>
Date: Mon, 25 Nov 2013 14:50:13 +0000
Subject: [PATCH] feature(pipe) add notEnd

---
 lib/server/files.js | 6 ++++--
 lib/server/pipe.js  | 4 +++-
 2 files changed, 7 insertions(+), 3 deletions(-)

diff --git a/lib/server/files.js b/lib/server/files.js
index 6a174553..e16bb1cf 100644
--- a/lib/server/files.js
+++ b/lib/server/files.js
@@ -82,13 +82,15 @@
             pipe.create({
                 from    : name,
                 write   : writeStream,
+                notEnd  : true,
                 callback: function(error) {
                     if (error)
                         Util.exec(callback, error);
                     else
-                        if (!length)
+                        if (!length) {
+                            writeStream.end();
                             Util.exec(callback);
-                        else
+                        } else
                             readPipe(files, dir, writeStream, callback);
                 }
             });
diff --git a/lib/server/pipe.js b/lib/server/pipe.js
index 5e9a3580..749ddd47 100644
--- a/lib/server/pipe.js
+++ b/lib/server/pipe.js
@@ -51,7 +51,9 @@
                 });
                 
                 lRead.on('end', function() {
-                    lWrite.end();
+                    if (!p.notEnd)
+                        lWrite.end();
+                    
                     Util.exec(p.callback);
                 });
             }, function(pCallBack) {