An reactive-extension library for java inspired by the reactive-streams.org initiative.