Update Clojure interop to support new OnSubscribeFunc with rx/fn.