Merge pull request #851 from xgrommx/master

Some updates

Author: mattpodwysocki

dist/rx.all.compat.js

@@ -6284,7 +6284,16 @@ Rx.Observable.prototype.flatMapLatest = function(selector, resultSelector, thisA
     }, source);
   };
 
-  var spawn = Observable.spawn = function () {
+var wrap = Observable.wrap = function (fn) {
+    createObservable.__generatorFunction__ = fn;
+    return createObservable;
+
+    function createObservable() {
+        return Observable.spawn.call(this, fn.apply(this, arguments));
+    }
+};
+
+var spawn = Observable.spawn = function () {
     var gen = arguments[0], self = this, args = [];
     for (var i = 1, len = arguments.length; i < len; i++) { args.push(arguments[i]); }
 
@@ -6315,6 +6324,7 @@ Rx.Observable.prototype.flatMapLatest = function(selector, resultSelector, thisA
         if (ret.done) {
           o.onNext(ret.value);
           o.onCompleted();
+          return;
         }
         var value = toObservable.call(self, ret.value);
         if (Observable.isObservable(value)) {
@@ -6341,7 +6351,7 @@ Rx.Observable.prototype.flatMapLatest = function(selector, resultSelector, thisA
 
   function arrayToObservable (obj) {
     return Observable.from(obj)
-      .map(toObservable, this)
+      .flatMap(toObservable)
       .toArray();
   }
 

dist/rx.all.compat.map

@@ -6182,7 +6182,16 @@ Rx.Observable.prototype.flatMapLatest = function(selector, resultSelector, thisA
     }, source);
   };
 
-  var spawn = Observable.spawn = function () {
+var wrap = Observable.wrap = function (fn) {
+    createObservable.__generatorFunction__ = fn;
+    return createObservable;
+
+    function createObservable() {
+        return Observable.spawn.call(this, fn.apply(this, arguments));
+    }
+};
+
+var spawn = Observable.spawn = function () {
     var gen = arguments[0], self = this, args = [];
     for (var i = 1, len = arguments.length; i < len; i++) { args.push(arguments[i]); }
 
@@ -6213,6 +6222,7 @@ Rx.Observable.prototype.flatMapLatest = function(selector, resultSelector, thisA
         if (ret.done) {
           o.onNext(ret.value);
           o.onCompleted();
+          return;
         }
         var value = toObservable.call(self, ret.value);
         if (Observable.isObservable(value)) {
@@ -6239,7 +6249,7 @@ Rx.Observable.prototype.flatMapLatest = function(selector, resultSelector, thisA
 
   function arrayToObservable (obj) {
     return Observable.from(obj)
-      .map(toObservable, this)
+      .flatMap(toObservable)
       .toArray();
   }
 

dist/rx.all.compat.min.js

@@ -63,7 +63,16 @@
     throw e;
   }
 
-  var spawn = Observable.spawn = function () {
+var wrap = Observable.wrap = function (fn) {
+    createObservable.__generatorFunction__ = fn;
+    return createObservable;
+
+    function createObservable() {
+        return Observable.spawn.call(this, fn.apply(this, arguments));
+    }
+};
+
+var spawn = Observable.spawn = function () {
     var gen = arguments[0], self = this, args = [];
     for (var i = 1, len = arguments.length; i < len; i++) { args.push(arguments[i]); }
 
@@ -94,6 +103,7 @@
         if (ret.done) {
           o.onNext(ret.value);
           o.onCompleted();
+          return;
         }
         var value = toObservable.call(self, ret.value);
         if (Observable.isObservable(value)) {
@@ -120,7 +130,7 @@
 
   function arrayToObservable (obj) {
     return Observable.from(obj)
-      .map(toObservable, this)
+      .flatMap(toObservable)
       .toArray();
   }
 

dist/rx.all.js

@@ -63,7 +63,16 @@
     throw e;
   }
 
-  var spawn = Observable.spawn = function () {
+var wrap = Observable.wrap = function (fn) {
+    createObservable.__generatorFunction__ = fn;
+    return createObservable;
+
+    function createObservable() {
+        return Observable.spawn.call(this, fn.apply(this, arguments));
+    }
+};
+
+var spawn = Observable.spawn = function () {
     var gen = arguments[0], self = this, args = [];
     for (var i = 1, len = arguments.length; i < len; i++) { args.push(arguments[i]); }
 
@@ -94,6 +103,7 @@
         if (ret.done) {
           o.onNext(ret.value);
           o.onCompleted();
+          return;
         }
         var value = toObservable.call(self, ret.value);
         if (Observable.isObservable(value)) {
@@ -120,7 +130,7 @@
 
   function arrayToObservable (obj) {
     return Observable.from(obj)
-      .map(toObservable, this)
+      .flatMap(toObservable)
       .toArray();
   }