Reactive-Extensions
diff --git a/‎dist/rx.dom.compat.js‎
Lines changed: 5 additions & 4 deletions b/‎dist/rx.dom.compat.js‎
Lines changed: 5 additions & 4 deletions
diff --git a/‎dist/rx.dom.compat.min.js‎
Lines changed: 1 addition & 1 deletion b/‎dist/rx.dom.compat.min.js‎
Lines changed: 1 addition & 1 deletion
diff --git a/‎dist/rx.dom.js‎
Lines changed: 5 additions & 4 deletions b/‎dist/rx.dom.js‎
Lines changed: 5 additions & 4 deletions
diff --git a/‎dist/rx.dom.min.js‎
Lines changed: 1 addition & 1 deletion b/‎dist/rx.dom.min.js‎
Lines changed: 1 addition & 1 deletion
diff --git a/‎examples/Autocomplete/Autocomplete.html‎
Lines changed: 1 addition & 1 deletion b/‎examples/Autocomplete/Autocomplete.html‎
Lines changed: 1 addition & 1 deletion
diff --git a/‎examples/Autocomplete/autocomplete.js‎
Lines changed: 22 additions & 21 deletions b/‎examples/Autocomplete/autocomplete.js‎
Lines changed: 22 additions & 21 deletions
@@ -190,10 +190,11 @@
     events = events.split(' ');
 
     for(var i = 0, len = events.length; i < len; i++) {
-      var e = events[i];
-      dom[e] = function (element, selector) {
-        return fromEvent(element, e, selector);
-      };
+      (function (e) {
+        dom[e] = function (element, selector) {
+          return fromEvent(element, e, selector);
+        };
+      }(events[i]))
     }
   }());
 
 
@@ -122,10 +122,11 @@
     events = events.split(' ');
 
     for(var i = 0, len = events.length; i < len; i++) {
-      var e = events[i];
-      dom[e] = function (element, selector) {
-        return fromEvent(element, e, selector);
-      };
+      (function (e) {
+        dom[e] = function (element, selector) {
+          return fromEvent(element, e, selector);
+        };
+      }(events[i]))
     }
   }());
 
 
@@ -14,7 +14,7 @@
     <![endif]-->    
     </head>
 
-<body onload="initialize();">
+<body>
     <div class="container">
         <div class="page-header">
             <h1>RxJS for jQuery Bindings AutoComplete example</h1>
 
@@ -2,48 +2,49 @@
 
   function searchWikipedia (term) {
     var url = 'http://en.wikipedia.org/w/api.php?action=opensearch&format=json&search='
-      + term + '&callback=JSONPCallback';
-    return Rx.DOM.Request.jsonpRequest(url);
+      + encodeURIComponent(term) + '&callback=JSONPCallback';
+    return Rx.DOM.jsonpRequest(url);
   }
 
   function clearChildren (e) {
     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) {
+    var li = document.createElement('li');
+    li.innerHTML = text;
+    parent.appendChild(li);
+  }
+
   function initialize () {
     var input = document.getElementById('textInput'),
-      ul = document.getElementById('results')
+        ul = document.getElementById('results');
 
-    var keyup = Rx.Observable.fromEvent(input, 'keyup')
-      .map(function(ev) {
-        return ev.target.value;
-      })
-      .filter(function(text) {
-        return text.length > 2;
-      })
-      .throttle(500, Rx.Scheduler.requestAnimationFrameScheduler)
+    var keyup = Rx.DOM.keyup(input)
+      .map(function (ev) { return ev.target.value; })
+      .filter(function(text) { return text.length > 2; })
+      .throttle(500)
       .distinctUntilChanged();
 
     var searcher = keyup.flatMapLatest(searchWikipedia).map(function(d) { return d[1]; });
 
     searcher.subscribe(
       function (results) {                    
         clearChildren(ul);
-
-        for (var i = 0, len = results.length; i < len; i++) {
-          var li = document.createElement('li');
-          li.innerHTML = results[i];
-          ul.appendChild(li);
-        }
+        createChildren(results, ul);
       }, 
       function (error) {
         clearChildren(ul);
-        var li = document.createElement('li');
-        li.innerHTML = 'Error: ' + error.message;
-        ul.appendChild(li);
+        createElement('Error: ' + error.message, ul);
       }
     );
   }
 
-  window.onload = initialize;
+  Rx.DOM.ready().subscribe(initialize);
 }(window));