Fixing examples

Author: mattpodwysocki

dist/rx.dom.compat.js

@@ -796,7 +796,7 @@
 
     function noop() {}
 
-    var tasks = new Array(1000), taskId = 0, scheduleMethod, clearMethod = noop;
+    var tasks = [], taskId = 0, scheduleMethod, clearMethod = noop;
 
     var setImmediate = root.setImmediate, clearImmediate = root.clearImmediate;
 
@@ -817,8 +817,7 @@
     if (!!BrowserMutationObserver) {
 
       var observer = new BrowserMutationObserver(function() {
-        var toProcess = queue.slice(0);
-        queue = new Array(1000);
+        var toProcess = tasks.slice(0);
 
         toProcess.forEach(function (func) {
           func();
@@ -835,14 +834,14 @@
       }, false);
 
       scheduleMethod = function (action) {
-        var id = queueId++;
-        queue[id] = action;
+        var id = taskId++;
+        tasks[id] = action;
         element.setAttribute('drainQueue', 'drainQueue');
         return id;
       };
 
       var clearMethod = function(id) {
-        queue[id] = undefined;
+        delete tasks[id];
       };
     } else if (typeof setImmediate === 'function') {
       scheduleMethod = setImmediate;

dist/rx.dom.compat.map

@@ -718,7 +718,7 @@
 
     function noop() {}
 
-    var tasks = new Array(1000), taskId = 0, scheduleMethod, clearMethod = noop;
+    var tasks = [], taskId = 0, scheduleMethod, clearMethod = noop;
 
     var setImmediate = root.setImmediate, clearImmediate = root.clearImmediate;
 
@@ -739,8 +739,7 @@
     if (!!BrowserMutationObserver) {
 
       var observer = new BrowserMutationObserver(function() {
-        var toProcess = queue.slice(0);
-        queue = new Array(1000);
+        var toProcess = tasks.slice(0);
 
         toProcess.forEach(function (func) {
           func();
@@ -757,14 +756,14 @@
       }, false);
 
       scheduleMethod = function (action) {
-        var id = queueId++;
-        queue[id] = action;
+        var id = taskId++;
+        tasks[id] = action;
         element.setAttribute('drainQueue', 'drainQueue');
         return id;
       };
 
       var clearMethod = function(id) {
-        queue[id] = undefined;
+        delete tasks[id];
       };
     } else if (typeof setImmediate === 'function') {
       scheduleMethod = setImmediate;

dist/rx.dom.compat.min.js

@@ -7,13 +7,13 @@
   }
 
   function clearChildren (e) {
-    while (e.firstChild) { e.removeChild(e.firstChild); }                
+    while (e.firstChild) { e.removeChild(e.firstChild); }
   }
 
   function createChildren(results, parent) {
     for (var i = 0, len = results.length; i < len; i++) {
       createElement(results[i], parent);
-    }    
+    }
   }
 
   function createElement(text, parent) {
@@ -25,20 +25,20 @@
   function initialize () {
     var input = document.getElementById('textInput'),
         ul = document.getElementById('results');
-        
+
     var keyup = Rx.DOM.keyup(input)
       .map(function (ev) { return ev.target.value; })
       .filter(function(text) { return text.length > 2; })
-      .throttle(500)
+      .debounce(500)
       .distinctUntilChanged();
 
-    var searcher = keyup.flatMapLatest(searchWikipedia).map(function(d) { return d[1]; });
+    var searcher = keyup.flatMapLatest(searchWikipedia).map(function(d) { return d.response[1]; });
 
     searcher.subscribe(
-      function (results) {                    
+      function (results) {
         clearChildren(ul);
         createChildren(results, ul);
-      }, 
+      },
       function (error) {
         clearChildren(ul);
         createElement('Error: ' + error.message, ul);
@@ -47,4 +47,4 @@
   }
 
   Rx.DOM.ready().subscribe(initialize);
-}(window));
+}(window));

dist/rx.dom.js

@@ -13,11 +13,11 @@
     });
 
     request.subscribe(
-      function (xhr) {
-        result.textContent = 'Page Title: ' + getTitle(xhr.responseText);
+      function (x) {
+        result.textContent = 'Page Title: ' + getTitle(x.xhr.responseText);
       },
       function (err) {
-        result.textContent = 'Error response: ' + xhr.message;
+        result.textContent = 'Error response: ' + err;
       }
     )
   }

dist/rx.dom.map

@@ -3,14 +3,14 @@
   function initialize() {
     var ul = document.getElementById('results');
 
-    Rx.Observable.range(0, 10, Rx.Scheduler.mutationObserver)
+    Rx.Observable.range(0, 10, Rx.Scheduler.microtask)
       .subscribe(function (results) {
         var li = document.createElement('li');
         li.innerHTML = results;
-        ul.appendChild(li);      
+        ul.appendChild(li);
       });
   }
 
   Rx.DOM.ready().subscribe(initialize);
 
-}(window));
+}(window));

dist/rx.dom.min.js

@@ -5,7 +5,7 @@
 
     function noop() {}
 
-    var tasks = new Array(1000), taskId = 0, scheduleMethod, clearMethod = noop;
+    var tasks = [], taskId = 0, scheduleMethod, clearMethod = noop;
 
     var setImmediate = root.setImmediate, clearImmediate = root.clearImmediate;
 
@@ -26,8 +26,7 @@
     if (!!BrowserMutationObserver) {
 
       var observer = new BrowserMutationObserver(function() {
-        var toProcess = queue.slice(0);
-        queue = new Array(1000);
+        var toProcess = tasks.slice(0);
 
         toProcess.forEach(function (func) {
           func();
@@ -44,14 +43,14 @@
       }, false);
 
       scheduleMethod = function (action) {
-        var id = queueId++;
-        queue[id] = action;
+        var id = taskId++;
+        tasks[id] = action;
         element.setAttribute('drainQueue', 'drainQueue');
         return id;
       };
 
       var clearMethod = function(id) {
-        queue[id] = undefined;
+        delete tasks[id];
       };
     } else if (typeof setImmediate === 'function') {
       scheduleMethod = setImmediate;