@effection/channel - npm Package Compare versions

Comparing version 2.0.0-preview.3-30fb124 to 2.0.0-preview.3-409df56

dist/channel.cjs.development.js

@@ -24,4 +24,3 @@ 'use strict';
         var _yield$subscription$n = yield subscription.next(),
-            _yield$subscription$n2 = _yield$subscription$n.value,
-            next = _yield$subscription$n2[0];
+            next = _yield$subscription$n.value;
 
@@ -28,0 +27,0 @@ if (next.done) {

dist/channel.cjs.production.min.js

@@ -1,2 +0,2 @@
-"use strict";var e=require("@effection/subscription"),n=require("@effection/events"),t=require("events");exports.createChannel=function(r){void 0===r&&(r={});var i=new t.EventEmitter;r.maxSubscribers&&i.setMaxListeners(r.maxSubscribers);var s=e.createStream((function(e){return function*(t){for(var r=n.on(i,"event").subscribe(t);;){var s=(yield r.next()).value[0];if(s.done)return s.value;e(s.value)}}}));return Object.assign({stream:s,send:function(e){i.emit("event",{done:!1,value:e})},close:function(){i.emit("event",{done:!0,value:arguments.length<=0?void 0:arguments[0]})}},s)};
+"use strict";var e=require("@effection/subscription"),n=require("@effection/events"),t=require("events");exports.createChannel=function(r){void 0===r&&(r={});var i=new t.EventEmitter;r.maxSubscribers&&i.setMaxListeners(r.maxSubscribers);var s=e.createStream((function(e){return function*(t){for(var r=n.on(i,"event").subscribe(t);;){var s=(yield r.next()).value;if(s.done)return s.value;e(s.value)}}}));return Object.assign({stream:s,send:function(e){i.emit("event",{done:!1,value:e})},close:function(){i.emit("event",{done:!0,value:arguments.length<=0?void 0:arguments[0]})}},s)};
 //# sourceMappingURL=channel.cjs.production.min.js.map

dist/channel.esm.js

@@ -22,4 +22,3 @@ import { createStream } from '@effection/subscription';
         var _yield$subscription$n = yield subscription.next(),
-            _yield$subscription$n2 = _yield$subscription$n.value,
-            next = _yield$subscription$n2[0];
+            next = _yield$subscription$n.value;
 
@@ -26,0 +25,0 @@ if (next.done) {

package.json

 {
   "name": "@effection/channel",
-  "version": "2.0.0-preview.3-30fb124",
+  "version": "2.0.0-preview.3-409df56",
   "description": "MPMC Channel implementation for effection",
@@ -23,6 +23,7 @@ "main": "dist/index.js",
   "devDependencies": {
+    "@effection/mocha": "2.0.0-preview.2",
     "@frontside/tsconfig": "^0.0.1",
     "@types/node": "^12.7.11",
     "expect": "^25.4.0",
-    "mocha": "^7.2.0",
+    "mocha": "^8.3.1",
     "ts-node": "^8.9.0",
@@ -29,0 +30,0 @@ "tsdx": "0.13.2",

src/channel.ts

@@ -25,3 +25,3 @@ import { createStream, Stream } from '@effection/subscription';
     while(true) {
-      let { value: [next] } = yield subscription.next();
+      let { value: next } = yield subscription.next();
       if(next.done) {
@@ -28,0 +28,0 @@ return next.value;

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

Worsened metrics

Total package byte prevSize

17215

decreased by-0.62%

Dev dependency count

8

increased by14.29%

Lines of code

146

decreased by-1.35%

No dependency changes