fluture - npm Package Compare versions

Comparing version 8.0.1 to 8.0.2

index.js

 (function (global, factory) {
-	typeof exports === 'object' && typeof module !== 'undefined' ? module.exports = factory(require('sanctuary-type-classes'), require('inspect-f'), require('sanctuary-type-identifiers'), require('concurrify'), require('denque')) :
-	typeof define === 'function' && define.amd ? define(['sanctuary-type-classes', 'inspect-f', 'sanctuary-type-identifiers', 'concurrify', 'denque'], factory) :
-	(global.Fluture = factory(global.sanctuaryTypeClasses,global.inspectf,global.sanctuaryTypeIdentifiers,global.concurrify,global.Denque));
-}(this, (function (Z,inspectf,type,concurrify,Denque) { 'use strict';
+	typeof exports === 'object' && typeof module !== 'undefined' ? module.exports = factory(require('sanctuary-type-classes'), require('inspect-f'), require('sanctuary-type-identifiers'), require('denque'), require('concurrify')) :
+	typeof define === 'function' && define.amd ? define(['sanctuary-type-classes', 'inspect-f', 'sanctuary-type-identifiers', 'denque', 'concurrify'], factory) :
+	(global.Fluture = factory(global.sanctuaryTypeClasses,global.inspectf,global.sanctuaryTypeIdentifiers,global.Denque,global.concurrify));
+}(this, (function (Z,inspectf,type,Denque,concurrify) { 'use strict';
 
@@ -10,4 +10,4 @@ Z = Z && Z.hasOwnProperty('default') ? Z['default'] : Z;
 type = type && type.hasOwnProperty('default') ? type['default'] : type;
+Denque = Denque && Denque.hasOwnProperty('default') ? Denque['default'] : Denque;
 concurrify = concurrify && concurrify.hasOwnProperty('default') ? concurrify['default'] : concurrify;
-Denque = Denque && Denque.hasOwnProperty('default') ? Denque['default'] : Denque;
 
@@ -542,3 +542,3 @@ /* istanbul ignore file: environment-specific */
   var open = true;
-  var f = this._computation(function Computation$rej(x){
+  var cancel = this._computation(function Computation$rej(x){
     if(open){
@@ -554,7 +554,9 @@ open = false;
   });
-  check$fork(f, this._computation);
+  check$fork(cancel, this._computation);
 
   return function Computation$cancel(){
-    open && f && f();
-    open = false;
+    if(open){
+      open = false;
+      cancel && cancel();
+    }
   };
@@ -2163,2 +2165,3 @@ };
   function Parallel$cancel(){
+    cursor = _length;
     for(var n = 0; n < _length; n++) cancels[n] && cancels[n]();
@@ -2165,0 +2168,0 @@ }

package.json

 {
   "name": "fluture",
-  "version": "8.0.1",
+  "version": "8.0.2",
   "description": "FantasyLand compliant (monadic) alternative to Promises",
@@ -65,3 +65,3 @@ "main": "index.js",
   "devDependencies": {
-    "@std/esm": "0.19.3",
+    "@std/esm": "~0.21.0",
     "benchmark": "^2.1.0",
@@ -79,10 +79,10 @@ "chai": "^4.1.2",
     "lodash.curry": "^4.1.1",
-    "mocha": "^4.0.0",
+    "mocha": "^5.0.0",
     "nyc": "^11.2.1",
     "ramda": "^0.25.0",
     "ramda-fantasy": "^0.8.0",
-    "remark-cli": "^4.0.0",
+    "remark-cli": "^5.0.0",
     "remark-validate-links": "^7.0.0",
     "rimraf": "^2.6.2",
-    "rollup": "^0.54.0",
+    "rollup": "^0.55.0",
     "rollup-plugin-commonjs": "^8.2.1",
@@ -89,0 +89,0 @@ "rollup-plugin-node-resolve": "^3.0.0",

src/core.js

@@ -241,3 +241,3 @@ import {show, showf, noop, moop} from './internal/fn';
   var open = true;
-  var f = this._computation(function Computation$rej(x){
+  var cancel = this._computation(function Computation$rej(x){
     if(open){
@@ -253,7 +253,9 @@ open = false;
   });
-  check$fork(f, this._computation);
+  check$fork(cancel, this._computation);
 
   return function Computation$cancel(){
-    open && f && f();
-    open = false;
+    if(open){
+      open = false;
+      cancel && cancel();
+    }
   };
@@ -260,0 +262,0 @@ };

src/parallel.js

@@ -30,2 +30,3 @@ import {Core, Resolved, isFuture} from './core';
   function Parallel$cancel(){
+    cursor = _length;
     for(var n = 0; n < _length; n++) cancels[n] && cancels[n]();
@@ -32,0 +33,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

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

205643

increased by0.06%

Lines of code

4121

increased by0.15%

No dependency changes