dncrht/rxjs_bacon.md

## rxjs_bacon.md

      
    Raw
  

              rxjs_bacon.md
            
          
    RxJS and Bacon.js equivalences:


Bacon.js
RxJS


Create stream for keyup events from an element
var inputText$ = $([data-js=my-input]).asEventStream('keyup').map('.target.value');
var inputText$ = Rx.Observable.fromEvent($('[data-js=my-input]'), 'keyup').pluck('target', 'value')


Create stream for keyup events from a live element
var inputText$ = $(document).asEventStream('keyup', '[data-js=my-input]').map('.target.value');
var inputText$ = Rx.Observable.create(function(observer) {$(document).on('keyup', '[data-js=my-input]', function(e) {observer.onNext(e.target.value);});});


Subscribe to a stream
inputText$.onValue(function(props) {…});
inputText$.subscribe(function(props) {…});


Create stream from promises
Bacon.fromPromise($.get(url, {text: text}));
Rx.Observable.fromPromise($.get(url, {text: text}));
	Bacon.js	RxJS
Create stream for keyup events from an element	var inputText$ = $([data-js=my-input]).asEventStream('keyup').map('.target.value');	var inputText$ = Rx.Observable.fromEvent($('[data-js=my-input]'), 'keyup').pluck('target', 'value')
Create stream for keyup events from a live element	var inputText$ = $(document).asEventStream('keyup', '[data-js=my-input]').map('.target.value');	var inputText$ = Rx.Observable.create(function(observer) {$(document).on('keyup', '[data-js=my-input]', function(e) {observer.onNext(e.target.value);});});
Subscribe to a stream	inputText$.onValue(function(props) {…});	inputText$.subscribe(function(props) {…});
Create stream from promises	Bacon.fromPromise($.get(url, {text: text}));	Rx.Observable.fromPromise($.get(url, {text: text}));