Implementation of https://github.com/reactive-streams/reactive-streams + Rx-style operators.
This project is just a fun proof-of-concept. It aims to provide a subset of RxJava methods but with a different implementation approach for operators.