Observables with RxJS

observable1.js

var Observable = Rx.Observable; 
var button = document.getElementById('button');
var clicks = Observable.fromEvent(button, 'click');

clicks.forEach(function( ){
   console.log('click')
});

// dispose 
var Observable = Rx.Observable; 
var button = document.getElementById('button');
var clicks = Observable.fromEvent(button, 'click');

var subscription = clicks.forEach(
  function next(event){
   console.log('click');
   subscription.dispose();
  }, 
  function onerror(error) {
    console.log('error');
  },
  function complete() {
    console.log('done');
  });s