feature(pipe) add notEnd

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

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) {