oboe
Oboe.js reads json, giving you the objects as they are found without waiting for the stream to finish
evnty
0-Deps, simple, fast, for browser and node js reactive anonymous event library
mongomq2
A general-purpose message and event queuing library for MongoDB
@thi.ng/rstream
Reactive streams & subscription primitives for constructing dataflow graphs / pipelines