npm install streams2gi
``js
var fs = require("fs")
, read = fs.createReadStream
, write = fs.createWriteStream
, wrap = require("streams2")
var stream = wrap(write("/tmp/noise"))
stream.end("some data")
stream.on("finish", function () {
// finished writing
})
var stream = wrap(read("/tmp/noise"))
consume(stream, function (chunk) {
// some data
})
function consume(stream, consumer) {
flow()
stream.on("readable", flow)
function flow() {
var chunk = stream.read()
while (chunk !== null) {
consumer(chunk)
chunk = stream.read()
}
}
}
`
npm install streams2`
- Raynos