blob: 72d2006fae57891bc3546090b1f7fa5a7d6243ad [file]
var fs = require('fs')
var JSONStream = require('JSONStream')
var BulkBadger = require('../')
fs
.createReadStream(__dirname + '/ldjson.json')
.pipe(JSONStream.parse())
.pipe(new BulkBadger({chunksize: 2}))
.pipe(JSONStream.stringify())
.pipe(process.stdout)