mirror of
https://github.com/coderaiser/cloudcmd.git
synced 2026-07-20 18:18:56 +00:00
feature(files) files, dir, writeStream, callback -> params
This commit is contained in:
parent
bea1e974c4
commit
f03cf93ab5
1 changed files with 11 additions and 12 deletions
|
|
@ -70,28 +70,27 @@
|
|||
|
||||
object.readPipe = readPipe;
|
||||
|
||||
function readPipe(files, dir, writeStream, callback) {
|
||||
var name, length = files && files.length;
|
||||
function readPipe(params) {
|
||||
var name,
|
||||
p = params,
|
||||
length = p.names && p.names.length;
|
||||
|
||||
if (!length) {
|
||||
writeStream.end();
|
||||
Util.exec(callback);
|
||||
p.write.end();
|
||||
Util.exec(p.callback);
|
||||
} else {
|
||||
name = dir + files.pop();
|
||||
name = p.dir + p.names.pop();
|
||||
|
||||
pipe.create({
|
||||
from : name,
|
||||
write : writeStream,
|
||||
write : p.write,
|
||||
gzip : p.gzip,
|
||||
notEnd : true,
|
||||
callback: function(error) {
|
||||
if (error)
|
||||
Util.exec(callback, error);
|
||||
Util.exec(p.callback, error);
|
||||
else
|
||||
if (!length) {
|
||||
writeStream.end();
|
||||
Util.exec(callback);
|
||||
} else
|
||||
readPipe(files, dir, writeStream, callback);
|
||||
readPipe(params);
|
||||
}
|
||||
});
|
||||
}
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue