A version of Rx implemented in Clojure using STM and agents. Intended to be a learning exercise.