An attempt to implement a subset of Rx on top of Node.js object streams