var Observable = Rx.Observable;

​

var parent = document.getElementById("parent");

var widget = document.getElementById("widget");

​

var mouseDowns = Observable.fromEvent(widget, "mousedown");

var parentMouseMoves = Observable.fromEvent(parent, "mousemove");

var parentMouseUps = Observable.fromEvent(parent, "mouseup");

​

/*

var filteredShownames = 

  IMDBShows.

    map(function(shows){

      return shows.showlist.filter(function(show) {

        return show.rating >= 9.00;

      });

    }).concatAll();

​

filteredShownames.forEach(function(name) {

  console.log(name);

});

*/

​

var drags = 

  mouseDowns.

    map(function(e) {

      return parentMouseMoves.

        takeUntil(parentMouseUps);

    }).

    concatAll();

​

var subscription = 

  drags.forEach(

    function onNext(e) {

      widget.style.left = e.clientX + "px";

      widget.style.top = e.clientY + "px";

    },

    function onError(error) {

      console.log('error');

    },

    function onCompleted() {

    });