Simple integration between RxJS and JSONStream
npm install rxjs-json-stream --save
const js = require("fs");
const stream = require("rxjs-json-stream");
const data = fs.createReadStream("data.json");
stream("*..id", data)
.map(entry => entry + 1)
.subscribe(entry => console.log(entry));
Code and documentation released under The MIT License (MIT).