rx_vs_bacon.ts

/// <reference path="./../typings/tsd.d.ts"/>
/// <reference path="./../node_modules/rx/ts/rx.all.d.ts"/>

import * as Rx from "rx";
import * as Bacon from "baconjs";

let rxstream = new Rx.Subject<string>();

let rxdispatcher = rxstream.do(_ => console.log("rxdo"));
rxdispatcher.subscribe(console.log);
rxdispatcher.subscribe(console.log);

rxstream.onNext("rxpayload");

let bstream = new Bacon.Bus<string, any>();

let bdispatcher = bstream.doAction(_ => console.log("bdo"));
bdispatcher.onValue(console.log);
bdispatcher.onValue(console.log);

bstream.push("bpayload");

/* output:
rxdo
rxpayload
rxdo
rxpayload
bdo
bpayload
bpayload
*/