Comparing RxJS on javascript and clojurescript

rxclj.cljs

(ns rxjsclj.core
  (:require [Rx]))

(defn stream-for [x]
  (.map (.interval js/Rx.Observable 2000) x))

(def providers (.from js/Rx.Observable [1 2 3]))

(-> (stream-for providers)
    (.concatMap #(.map % stream-for))
    (.mergeAll)
    (.forEach #(.log js/console (clj->js %))))

rxjs.js

var Rx = require('rx');

var streamFor = function (x) {
	return Rx.Observable.interval(2000).map(function () {
		return x;
	});
}

var providers = Rx.Observable.from([1, 2, 3]);

streamFor(providers).concatMap(function (providers) {
	return providers.map(function (provider) {
		return streamFor(provider);
	});
}).mergeAll().forEach(function (data) {
	console.log(data);
});