amit777

var Rx = require('rxjs');
var source;

var timeline = Rx.Observable.create(function(observer){
  var to;
  var last = null;
  source = observer;

  return function() {
    console.log('observer ended ');