feature(files) add readPipe

This commit is contained in:
coderaiser 2013-11-25 11:40:29 +00:00
parent 1ad1e7e14c
commit b621a05832

View file

@ -12,6 +12,7 @@
var main = global.cloudcmd.main,
fs = main.fs,
path = main.path,
pipe = main.pipe,
CloudFunc = main.cloudfunc,
Util = main.util;
@ -67,4 +68,30 @@
}
};
object.readPipe = readPipe;
function readPipe(files, writeStream, callback) {
var name, length = files && files.length;
if (!length)
Util.exec(callback);
else {
name = files.pop();
pipe.create({
from : name,
write : writeStream,
callback: function(error) {
if (error)
Util.exec(callback, error);
else
if (!length)
Util.exec(callback);
else
readPipe(files, writeStream, callback);
}
});
}
}
})(this);