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()
        }
    }
}