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));