An OCaml implementation of Rx Observables - View it on GitHub