See also IxJS, which is a pull-based version of RxJS:

https://github.com/ReactiveX/IxJS