Mirrors/cloudcmd
1
0
Fork 0
mirror of https://github.com/coderaiser/cloudcmd.git synced 2026-07-28 10:14:13 +00:00
Code Issues Projects Releases Wiki Activity

refactor(stream) stream -> pipe

Browse source
This commit is contained in:
coderaiser 2013-09-16 13:57:58 +00:00
parent 9ba0fb377e
commit 02b06c4395
3 changed files with 7 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

60
lib/server/pipe.js Normal file
View file

@ -0,0 +1,60 @@
(function () {
'use strict';
if (!global.cloudcmd)
return console.log(
'# pipe.js' + '\n' +
'# -----------' + '\n' +
'# Module is part of Cloud Commander,' + '\n' +
'# used for work with stream.' + '\n' +
'# If you wont to see at work call' + '\n' +
'# stream.createPipe' + '\n' +
'# http://coderaiser.github.io/cloudcmd' + '\n');
var main = global.cloudcmd.main,
fs = main.fs,
Util = main.util,
zlib = main.zlib;
exports.create = function(pParams) {
var lZlib, lError, lMsg, lRead, lWrite, lIsFsWrite,
p = pParams;
if (p) {
lRead = p.read || fs.createReadStream(p.from, {
bufferSize: 4 * 1024
});
if (p.write)
lWrite = p.write;
else {
lWrite = fs.createWriteStream(p.to);
lIsFsWrite = true;
}
lError = function(pError) {
Util.exec(p.callback, pError);
};
if (p.zip) {
lZlib = zlib.createGzip();
lRead.on('error', lError);
lRead = lRead.pipe(lZlib);
}
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 {
lRead.pipe(lWrite);
lRead.on('end', Util.retExec(p.callback));
}
}
};
})();