Updating konami code

Author: mattpodwysocki

examples/KonamiCode/konamicode.js

@@ -1,22 +1,31 @@
-(function () {
+(function (window, undefined) {
 
-  function main () {
+  function fadeOut(element) {
+    var opacity = 1;
+    element.style.opacity = opacity;
+
+    var subscription = Rx.Scheduler.timeout.schedulePeriodic(100, function () {
+      opacity === 0 && subscription.dispose();
+      opacity -= 0.1;
+      element.style.opacity = opacity;
+    });
+  }
+
+  function initialize() {
 
     var codes = [38, 38, 40, 40, 37, 39, 37, 39, 66, 65],
       konami = Rx.Observable.fromArray(codes),
       result = document.getElementById('result');
 
-    Rx.Observable.fromEvent(document, 'keyup')
+    Rx.DOM.keyup(document)
       .pluck('keyCode')
       .bufferWithCount(10, 10)
       .filter(function (data) { return data.toString() === codes.toString(); })
       .subscribe(function () {
-          result.innerHTML = 'KONAMI!';
-          setTimeout(function () {
-              result.style.opacity = 0;
-          }, 2000);
+        result.innerHTML = 'KONAMI!';
+        fadeOut(result);
       });
   }
 
-  window.onload = main;
-})();
+  Rx.DOM.ready().subscribe(initialize);
+})(window);

examples/dragndrop/dragndrop.js

@@ -1,14 +1,14 @@
 (function (window, undefined) {
 
-  function main () {
+  function initialize () {
     var dragTarget = document.getElementById('dragTarget');
 
     // Get the three major events
-    var mouseup = Rx.Observable.fromEvent(dragTarget, 'mouseup');
-    var mousemove = Rx.Observable.fromEvent(document, 'mousemove');
-    var mousedown = Rx.Observable.fromEvent(dragTarget, 'mousedown');
+    var mouseup   = Rx.DOM.mouseup(dragTarget);
+    var mousemove = Rx.DOM.mousemove(document);
+    var mousedown = Rx.DOM.mousedown(dragTarget);
 
-    var mousedrag = mousedown.selectMany(function (md) {
+    var mousedrag = mousedown.flatMap(function (md) {
 
       // calculate offsets when mouse down
       var startX = md.offsetX, startY = md.offsetY;
@@ -31,6 +31,6 @@
     });
   }
 
-  window.onload = main;
+  Rx.DOM.ready().subscribe(initialize);
 
 }(window));