rawStream.pipe(JSONStream.parse()).pipe(streamOfObjects) - View it on GitHub