var Observable = Rx.Observable;

​

var source1 = Observable.create(function(observer){

    observer.error();

});

var source2 = Observable.create(function(observer){

    observer.next('Continuing on');

    observer.complete();

});

​

​

var stream = source1.catch(function(data){

  return source2;

});

​

​

​

stream.subscribe(function(data){

  console.log(data);

});