0.1.2 • Published 8 years ago
clazy v0.1.2
clazy
wait for the end of multiple asynchronous processing.
usage
var Clazy = require('clazy')
var fs = require('fs')
var path = require('path')
// lazyStream.add(stream)
var lazyStream = new Clazy
lazyStream
.on('error', console.error.bind(console))
.on('data', function (ping) {
console.dir(ping)
})
.on('end', function () {
console.log('Copy completed')
})
;[
'path/to/img1.jpg'
, 'path/to/img2.jpg'
, 'path/to/img3.jpg'
].forEach(function (imgPath) {
var savePath = path.join('path/to/cp/', path.basename(imgPath))
var readStream = fs.createReadStream(imgPath)
var writeStream = fs.createWriteStream(savePath)
lazyStream.add(readStream.pipe(writeStream))
})
// lazyStream.wait(function (clear) { ... })
var lazyStream = new Clazy
lazyStream
.on('error', console.error.bind(console))
.on('data', function (ping) {
console.dir(ping)
})
.on('end', function () {
console.log('all works completed')
})
;[5,3,4,1,2].forEach(function (s) {
lazyStream.wait(functon (clear) {
setTimeout(function () {
console.log(s)
clear()
}, s * 1000)
})
})
api
var clazyStream = new Clazy
create a new lazy stream. this stream is readable.
clazyStream.add(stream)
clazyStream issue the data when added stream
has ended (or finised).
the data is the order in witch they are registered clazyStream.
however, if the stream emit error, clazyStream will emit error.
clazyStream will emit end when all streams has ended (or finished).
clazyStream.wait(function (clear) {
// asyncwork has ended -> clear()
// asyncwork has error -> clear(err)
})
License
MIT
author
ishiduca