let Observable = Rx.Observable

​

let errorButton = document.getElementById('error')

​

let errorClicks = Observable.fromEvent(errorButton, 'click')

​

errorClicks.forEach(

  onNext = (x) => {

    console.log('clicked')

    throw('ERROR')

  }

).then(

  () => console.log('complete'),

  (e) => console.log('error', e)

)

​

let button = document.getElementById('button')

​

let clicks = Observable.fromEvent(button, 'click')

​

let points = 

    clicks.map((e) => ({

     x: e.clientX, y: e.clientY 

    }))

​

points.forEach((point) => {

    console.log(point)

  }

)

​