Reactive Extensions with Promises Interactions

rx-promises.js

// Using concat with promises.
var sources = Rx.Observable.concat(
  $.get('foo.json').promise,
  $.get('bar.json').promise,
  Rx.Observable.return(42) // Hey why not an observable as well
);

sources.subscribe(
  function (data) {
    // Do something with each piece of data.
  });
  
// Using defer
var source = Rx.Observable.defer(function () {
  return $.get('foo.json').promise;
});

// Using zip
var source = Rx.Observable.zip(
  $.get('foo.json').promise,
  $.get('bar.json').promise,
  function (foo, bar) { /* Do something to combine them */ });
  
// Run in parallel
var source = Rx.Observable.forkJoin(
  $.get('foo.json').promise,
  $.get('bar.json').promise
);

// What you can't get from promises spec

// Cancellation
var source = Rx.Observable.fromPromise($.get('foo.json').promise);
var subscription = source.subscribe(...);

// Cancel the value of the promise if it hasn't come back yet
subscription.dispose(); 

// Easy retry
var source = Rx.Observable.fromPromise($.get('foo.json').promise)
  .retry(3);
  
// Either timeout or another value
var source = Rx.Observable.fromPromise($.get('foo.json').promise)
  .timeout(500, Rx.Observable.return(42));