0.2.0 • Published 8 years ago
heka-decode-stream v0.2.0
heka-stream
Stream Heka's frame delimited protobuf messages
Example
var fs = require('fs')
var zlib = require('zlib')
var HekaStream = require('heka-stream')
fs.createReadStream(__dirname + '/data.gz')
.pipe(zlib.createGunzip())
.pipe(HekaStream.createDecodeStream())
.on('data', function (message) {
console.log(message.type)
console.log(message.fields)
})