rx-observable.js

var Rx = require('rx');
// buat sumber datangnya event
var button = document.querySelector('.myButton');
// buat observable (dari sumber event yakny 'click' event dari element button)
var buttonObservable = Rx.Observable.fromEvent(button, 'click');

// buat observer 
var subscription = buttonObservable
  .map(function(event) {
    return "Saya di klik!"
  })
  .subscribe(
    // onNext() event
    function(message) {
      console.log(message)
    },
    // onError() event
    function(err) {
      console.log(err)
    },
    // stop observing
    function() {
      console.log('im done!')
    }
  );
// jika selesai atau sudah tidak butuh
subscription.dispose()
// <= "im done!"