@effection/channel - npm Package Compare versions

Comparing version 2.0.0-preview.0 to 2.0.0-preview.0-57f61c8

dist/channel.cjs.development.js

@@ -32,41 +32,16 @@ 'use strict';
     return subscription.Subscription.create(task, function (publish) {
-      return /*#__PURE__*/regeneratorRuntime.mark(function _callee() {
-        var subscription, _yield$subscription$e, event;
+      return function* () {
+        var subscription = events.on(task, bus, 'event');
 
-        return regeneratorRuntime.wrap(function _callee$(_context) {
-          while (1) {
-            switch (_context.prev = _context.next) {
-              case 0:
-                subscription = events.on(task, bus, 'event');
+        while (true) {
+          var _yield$subscription$e = yield subscription.expect(),
+              event = _yield$subscription$e[0];
 
-              case 1:
-
-                _context.next = 4;
-                return subscription.expect();
-
-              case 4:
-                _yield$subscription$e = _context.sent;
-                event = _yield$subscription$e[0];
-
-                if (!event.done) {
-                  _context.next = 10;
-                  break;
-                }
-
-                return _context.abrupt("return", event.value);
-
-              case 10:
-                publish(event.value);
-
-              case 11:
-                _context.next = 1;
-                break;
-
-              case 13:
-              case "end":
-                return _context.stop();
-            }
+          if (event.done) {
+            return event.value;
+          } else {
+            publish(event.value);
           }
-        }, _callee);
-      });
+        }
+      };
     });
@@ -73,0 +48,0 @@ };

dist/channel.cjs.production.min.js

@@ -1,2 +0,2 @@
-"use strict";var e=require("@effection/subscription"),t=require("@effection/events"),n=require("events");exports.Channel=function(){function r(){this.bus=new n.EventEmitter}var s=r.prototype;return s[e.SymbolOperationIterable]=function(e){return this.subscribe(e)},s.setMaxListeners=function(e){this.bus.setMaxListeners(e)},s.send=function(e){this.bus.emit("event",{done:!1,value:e})},s.subscribe=function(n){var r=this.bus;return e.Subscription.create(n,(function(e){return regeneratorRuntime.mark((function s(){var i,u;return regeneratorRuntime.wrap((function(s){for(;;)switch(s.prev=s.next){case 0:i=t.on(n,r,"event");case 1:return s.next=4,i.expect();case 4:if(!(u=s.sent[0]).done){s.next=10;break}return s.abrupt("return",u.value);case 10:e(u.value);case 11:s.next=1;break;case 13:case"end":return s.stop()}}),s)}))}))},s.close=function(){this.bus.emit("event",{done:!0,value:arguments.length<=0?void 0:arguments[0]})},r}();
+"use strict";var e=require("@effection/subscription"),t=require("@effection/events"),n=require("events");exports.Channel=function(){function i(){this.bus=new n.EventEmitter}var r=i.prototype;return r[e.SymbolOperationIterable]=function(e){return this.subscribe(e)},r.setMaxListeners=function(e){this.bus.setMaxListeners(e)},r.send=function(e){this.bus.emit("event",{done:!1,value:e})},r.subscribe=function(n){var i=this.bus;return e.Subscription.create(n,(function(e){return function*(){for(var r=t.on(n,i,"event");;){var s=(yield r.expect())[0];if(s.done)return s.value;e(s.value)}}}))},r.close=function(){this.bus.emit("event",{done:!0,value:arguments.length<=0?void 0:arguments[0]})},i}();
 //# sourceMappingURL=channel.cjs.production.min.js.map

dist/channel.esm.js

@@ -30,41 +30,16 @@ import { SymbolOperationIterable, Subscription } from '@effection/subscription';
     return Subscription.create(task, function (publish) {
-      return /*#__PURE__*/regeneratorRuntime.mark(function _callee() {
-        var subscription, _yield$subscription$e, event;
+      return function* () {
+        var subscription = on(task, bus, 'event');
 
-        return regeneratorRuntime.wrap(function _callee$(_context) {
-          while (1) {
-            switch (_context.prev = _context.next) {
-              case 0:
-                subscription = on(task, bus, 'event');
+        while (true) {
+          var _yield$subscription$e = yield subscription.expect(),
+              event = _yield$subscription$e[0];
 
-              case 1:
-
-                _context.next = 4;
-                return subscription.expect();
-
-              case 4:
-                _yield$subscription$e = _context.sent;
-                event = _yield$subscription$e[0];
-
-                if (!event.done) {
-                  _context.next = 10;
-                  break;
-                }
-
-                return _context.abrupt("return", event.value);
-
-              case 10:
-                publish(event.value);
-
-              case 11:
-                _context.next = 1;
-                break;
-
-              case 13:
-              case "end":
-                return _context.stop();
-            }
+          if (event.done) {
+            return event.value;
+          } else {
+            publish(event.value);
           }
-        }, _callee);
-      });
+        }
+      };
     });
@@ -71,0 +46,0 @@ };

package.json

 {
   "name": "@effection/channel",
-  "version": "2.0.0-preview.0",
+  "version": "2.0.0-preview.0-57f61c8",
   "description": "MPMC Channel implementation for effection",
@@ -26,3 +26,3 @@ "main": "dist/index.js",
     "ts-node": "^8.9.0",
-    "tsdx": "^0.13.2",
+    "tsdx": "0.13.2",
     "typescript": "^3.7.0"
@@ -29,0 +29,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

Worsened metrics

Total package byte prevSize

15274

decreased by-10.36%

Lines of code

116

decreased by-24.18%

No dependency changes