Rx Catch

HTML

<div class="container">
    <div class="header">
         <a href="#" class="this">BUTTON</a>
    </div>
</div>
<pre id="output"></pre>
<script src="http://cdnjs.cloudflare.com/ajax/libs/rxjs/2.2.26/rx.js"></script>
<script src="http://cdnjs.cloudflare.com/ajax/libs/rxjs/2.2.26/rx.async.js"></script>
<script src="http://cdnjs.cloudflare.com/ajax/libs/rxjs/2.2.26/rx.coincidence.js"></script>
<script src="http://cdnjs.cloudflare.com/ajax/libs/rxjs/2.2.26/rx.binding.js"></script>
<script src="http://cdnjs.cloudflare.com/ajax/libs/rxjs/2.2.26/rx.time.js"></script>
<script src="http://cdnjs.cloudflare.com/ajax/libs/rxjs-dom/2.0.7/rx.dom.js"></script>

CSS

body {
    font-family: sans-serif;
    padding: 10px;
}
h2 {
    font-weight: bold;
    display: inline-block;
    margin-left: 20px;
}
.header {
    background: #ECECEC;
    padding: 5px;
}

JavaScript

function out() {
  var args = Array.prototype.slice.call(arguments, 0);
  document.getElementById('output').innerHTML += args.join(" ") + "\n";
}

function noop(){} // does nothing

var button = document.querySelector('.this');
var testCount = 0;
var obsSubject = Rx.Observable.fromEvent(button, 'click');

obsSubject.map(function () {
  testCount++;
  if (testCount % 4 === 0) {
      throw new Error("something to catch");
  }
  return testCount;
})
.onErrorResumeNext(function(e) {
  out("handle the error:",e);
  return Rx.Observable.return(200);
})
.subscribe(function (x) {
  out("subscriber on next:",x);
}, function(e){
  out("subscriber on error:",e);
});