diff --git a/examples/stream-multiple/stream-multiple.js b/examples/stream-multiple/stream-multiple.js index 0012d8485..e21fc43b6 100644 --- a/examples/stream-multiple/stream-multiple.js +++ b/examples/stream-multiple/stream-multiple.js @@ -2,49 +2,30 @@ var needle = require('needle'); const fs = require('fs-extra') function stream_multiple(req, res, _urls, stream_dir, index = 0) { - if (index == 0) { - // initial state + if (index == undefined) { + index = 0; + return stream_multiple(req, res, _urls, stream_dir, index); } let writeStream; const uri = _urls[index]; - if (index == undefined) { - index = 0; - stream_multiple(req, res, _urls, stream_dir, index); - } else { - - writeStream = fs.createWriteStream(`${stream_dir}` + `${index}.jpeg`); - - writeStream.on("ready", () => console.log({ msg: `STREAM::WRITE::READY::${index}` })); - writeStream.on("open", () => console.log({ msg: `STREAM::WRITE::OPEN::${index}` })); - writeStream.on("finish", () => console.log({ msg: `STREAM::WRITE::DONE::${index}` })); - - writeStream.on('close', () => { - if (index >= _urls.length - 1) { - res.redirect('/'); - } else { - stream_multiple(req, res, _urls, stream_dir, index + 1); - } - }) - - needle - .get(uri, function (error, response) { - if (response.bytes >= 1) { - // you want to kill our servers - } - - if (!error && response.statusCode == 200) { - // good - } else { - // then we can retry later - } - }) - .pipe(writeStream) - .on('done', function () { - // needle - }); - } + writeStream = fs.createWriteStream(`${stream_dir}${index}.jpeg`); + + writeStream.on('close', () => { + if (index >= _urls.length - 1) { + res.redirect('/'); + } else { + stream_multiple(req, res, _urls, stream_dir, index + 1); + } + }); + + needle + .get(uri) + .pipe(writeStream) + .on('done', () => { + // stream finished + }); } module.exports = { stream_multiple } \ No newline at end of file