Implementation of https://github.com/reactive-streams/reactive-streams + the Rx-style operators.