Adding mutation observer tests

Author: mattpodwysocki

dist/rx.dom.compat.js

@@ -918,7 +918,10 @@
     return Subject.create(new WorkerObserver(state), new WorkerObservable(state, url));
   };
 
-  var BrowserMutationObserver = root.MutationObserver || root.WebKitMutationObserver;
+  function getMutationObserver(next) {
+    var M = root.MutationObserver || root.WebKitMutationObserver;
+    return new M(next);
+  }
 
   var MutationObserverObservable = (function (__super__) {
     inherits(MutationObserverObservable, __super__);
@@ -941,7 +944,7 @@
     };
 
     MutationObserverObservable.prototype.subscribeCore = function (o) {
-      var mutationObserver = new BrowserMutationObserver(function (e) { o.onNext(e); });
+      var mutationObserver = getMutationObserver(function (e) { o.onNext(e); });
       mutationObserver.observe(this._target, this._options);
       return new InnerDisposable(mutationObserver);
     };
@@ -960,7 +963,7 @@
    * @returns {Observable} An observable sequence which contains mutations on the given DOM target.
    */
   dom.fromMutationObserver = function (target, options) {
-    if (!BrowserMutationObserver) { throw new TypeError('MutationObserver not implemented in your runtime.'); }
+    if (!(root.MutationObserver || root.WebKitMutationObserver)) { throw new TypeError('MutationObserver not implemented in your runtime.'); }
     return new MutationObserverObservable(target, options);
   };
 

dist/rx.dom.compat.map

@@ -777,7 +777,10 @@
     return Subject.create(new WorkerObserver(state), new WorkerObservable(state, url));
   };
 
-  var BrowserMutationObserver = root.MutationObserver || root.WebKitMutationObserver;
+  function getMutationObserver(next) {
+    var M = root.MutationObserver || root.WebKitMutationObserver;
+    return new M(next);
+  }
 
   var MutationObserverObservable = (function (__super__) {
     inherits(MutationObserverObservable, __super__);
@@ -800,7 +803,7 @@
     };
 
     MutationObserverObservable.prototype.subscribeCore = function (o) {
-      var mutationObserver = new BrowserMutationObserver(function (e) { o.onNext(e); });
+      var mutationObserver = getMutationObserver(function (e) { o.onNext(e); });
       mutationObserver.observe(this._target, this._options);
       return new InnerDisposable(mutationObserver);
     };
@@ -819,7 +822,7 @@
    * @returns {Observable} An observable sequence which contains mutations on the given DOM target.
    */
   dom.fromMutationObserver = function (target, options) {
-    if (!BrowserMutationObserver) { throw new TypeError('MutationObserver not implemented in your runtime.'); }
+    if (!(root.MutationObserver || root.WebKitMutationObserver)) { throw new TypeError('MutationObserver not implemented in your runtime.'); }
     return new MutationObserverObservable(target, options);
   };
 

dist/rx.dom.compat.min.js

@@ -918,7 +918,10 @@
     return Subject.create(new WorkerObserver(state), new WorkerObservable(state, url));
   };
 
-  var BrowserMutationObserver = root.MutationObserver || root.WebKitMutationObserver;
+  function getMutationObserver(next) {
+    var M = root.MutationObserver || root.WebKitMutationObserver;
+    return new M(next);
+  }
 
   var MutationObserverObservable = (function (__super__) {
     inherits(MutationObserverObservable, __super__);
@@ -941,7 +944,7 @@
     };
 
     MutationObserverObservable.prototype.subscribeCore = function (o) {
-      var mutationObserver = new BrowserMutationObserver(function (e) { o.onNext(e); });
+      var mutationObserver = getMutationObserver(function (e) { o.onNext(e); });
       mutationObserver.observe(this._target, this._options);
       return new InnerDisposable(mutationObserver);
     };
@@ -960,7 +963,7 @@
    * @returns {Observable} An observable sequence which contains mutations on the given DOM target.
    */
   dom.fromMutationObserver = function (target, options) {
-    if (!BrowserMutationObserver) { throw new TypeError('MutationObserver not implemented in your runtime.'); }
+    if (!(root.MutationObserver || root.WebKitMutationObserver)) { throw new TypeError('MutationObserver not implemented in your runtime.'); }
     return new MutationObserverObservable(target, options);
   };
 

dist/rx.dom.js

@@ -271,7 +271,10 @@
     return Subject.create(new WorkerObserver(state), new WorkerObservable(state, url));
   };
 
-  var BrowserMutationObserver = root.MutationObserver || root.WebKitMutationObserver;
+  function getMutationObserver(next) {
+    var M = root.MutationObserver || root.WebKitMutationObserver;
+    return new M(next);
+  }
 
   var MutationObserverObservable = (function (__super__) {
     inherits(MutationObserverObservable, __super__);
@@ -294,7 +297,7 @@
     };
 
     MutationObserverObservable.prototype.subscribeCore = function (o) {
-      var mutationObserver = new BrowserMutationObserver(function (e) { o.onNext(e); });
+      var mutationObserver = getMutationObserver(function (e) { o.onNext(e); });
       mutationObserver.observe(this._target, this._options);
       return new InnerDisposable(mutationObserver);
     };
@@ -313,7 +316,7 @@
    * @returns {Observable} An observable sequence which contains mutations on the given DOM target.
    */
   dom.fromMutationObserver = function (target, options) {
-    if (!BrowserMutationObserver) { throw new TypeError('MutationObserver not implemented in your runtime.'); }
+    if (!(root.MutationObserver || root.WebKitMutationObserver)) { throw new TypeError('MutationObserver not implemented in your runtime.'); }
     return new MutationObserverObservable(target, options);
   };