zen-observable - npm Package Compare versions

Comparing version 0.8.6 to 0.8.7

lib/Observable.js

@@ -429,2 +429,60 @@ 'use strict';
   }, {
+    key: 'flatMap',
+    value: function flatMap(fn) {
+      var _this6 = this;
+
+      if (typeof fn !== 'function') throw new TypeError(fn + ' is not a function');
+
+      var C = getSpecies(this);
+
+      return new C(function (observer) {
+        var subscriptions = [];
+
+        var outer = _this6.subscribe({
+          next: function (value) {
+            if (fn) {
+              try {
+                value = fn(value);
+              } catch (e) {
+                return observer.error(e);
+              }
+            }
+
+            var inner = C.from(value).subscribe({
+              next: function (value) {
+                observer.next(value);
+              },
+              error: function (e) {
+                observer.error(e);
+              },
+              complete: function () {
+                var i = subscriptions.indexOf(inner);
+                if (i >= 0) subscriptions.splice(i, 1);
+                completeIfDone();
+              }
+            });
+
+            subscriptions.push(inner);
+          },
+          error: function (e) {
+            observer.error(e);
+          },
+          complete: function () {
+            completeIfDone();
+          }
+        });
+
+        function completeIfDone() {
+          if (outer.closed && subscriptions.length === 0) observer.complete();
+        }
+
+        return function () {
+          subscriptions.forEach(function (s) {
+            return s.unsubscribe();
+          });
+          outer.unsubscribe();
+        };
+      });
+    }
+  }, {
     key: getSymbol('observable'),
@@ -431,0 +489,0 @@ value: function () {

package.json

 {
   "name": "zen-observable",
-  "version": "0.8.6",
+  "version": "0.8.7",
   "repository": "zenparsing/zen-observable",
@@ -16,7 +16,7 @@ "description": "An Implementation of ES Observables",
   "scripts": {
-    "test": "mocha --recursive --require babel-core/register",
+    "test": "mocha --recursive --require ./scripts/mocha-require",
     "lint": "eslint src/*",
-    "build": "git clean -dfX ./lib && babel src --out-dir lib",
+    "build": "git clean -dfX ./lib && node ./scripts/build",
     "prepublishOnly": "eslint src/* && npm test && npm run build"
   }
 }

src/Observable.js

@@ -344,2 +344,46 @@ // === Symbol Support ===
 
+  flatMap(fn) {
+    if (typeof fn !== 'function')
+      throw new TypeError(fn + ' is not a function');
+
+    let C = getSpecies(this);
+
+    return new C(observer => {
+      let subscriptions = [];
+
+      let outer = this.subscribe({
+        next(value) {
+          if (fn) {
+            try { value = fn(value) }
+            catch (e) { return observer.error(e) }
+          }
+
+          let inner = C.from(value).subscribe({
+            next(value) { observer.next(value) },
+            error(e) { observer.error(e) },
+            complete() {
+              let i = subscriptions.indexOf(inner);
+              if (i >= 0) subscriptions.splice(i, 1);
+              completeIfDone();
+            },
+          });
+
+          subscriptions.push(inner);
+        },
+        error(e) { observer.error(e) },
+        complete() { completeIfDone() },
+      });
+
+      function completeIfDone() {
+        if (outer.closed && subscriptions.length === 0)
+          observer.complete();
+      }
+
+      return () => {
+        subscriptions.forEach(s => s.unsubscribe());
+        outer.unsubscribe();
+      };
+    });
+  }
+
   [getSymbol('observable')]() { return this }
@@ -346,0 +390,0 @@

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Shell access

Supply chain risk

This module accesses the system shell. Accessing the system shell increases the risk of executing arbitrary code.

Found 1 instance in 1 package

Environment variable access

Supply chain risk

Package accesses environment variables, which may be a sign of credential stuffing or data theft.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

70279

increased by5%

Number of package files

36

increased by9.09%

Lines of code

2116

increased by6.6%

Worsened metrics

Number of low supply chain risk alerts

2

increased by100%

Number of medium supply chain risk alerts

1

increased byInfinity%

No dependency changes