Adapt ES7 Object.observe to Rx.Observable

1_observations.js

var Observable = Rx.Observable;

Observable.fromObservations = function(obj) {
  return Observable.create(function forEach(observer) {
     var handler = changes => observer.onNext(changes);
     Object.observe(obj, handler);
 
     return function dispose() {     
       Object.unobserve(obj, handler); 
     };
  });
};

2_test.js

var person = {
  name: 'Jim'
};

Observable.
  fromObservations(person).
  take(1).
  forEach(x => console.log(x));

person.age = 23;
person.name = 'Don';

setTimeout(() => person.name = 'Thomas', 1000);