@effection/channel - npm Package Compare versions

Comparing version 2.0.0-preview.3-d36fe3e to 2.0.0-preview.3-ea472e7

dist/channel.cjs.development.js

@@ -34,3 +34,4 @@ 'use strict';
   });
-  return Object.assign(subscribable, {
+  return Object.assign({
+    stream: subscribable,
     send: function send(message) {
@@ -48,3 +49,3 @@ bus.emit('event', {
     }
-  });
+  }, subscribable);
 }
@@ -51,0 +52,0 @@

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 u=e.createStream((function(e){return function*(t){for(var r=n.on(i,"event").subscribe(t);;){var u=(yield r.next()).value;if(u.done)return u.value;e(u.value)}}}));return Object.assign(u,{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]})}})};
+"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.d.ts

@@ -8,3 +8,4 @@ import { Stream } from '@effection/subscription';
     close(...args: TClose extends undefined ? [] : [TClose]): void;
+    stream: Stream<T, TClose>;
 }
 export declare function createChannel<T, TClose = undefined>(options?: ChannelOptions): Channel<T, TClose>;

dist/channel.esm.js

@@ -32,3 +32,4 @@ import { createStream } from '@effection/subscription';
   });
-  return Object.assign(subscribable, {
+  return Object.assign({
+    stream: subscribable,
     send: function send(message) {
@@ -46,3 +47,3 @@ bus.emit('event', {
     }
-  });
+  }, subscribable);
 }
@@ -49,0 +50,0 @@

package.json

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

src/channel.ts

@@ -12,2 +12,3 @@ import { createStream, Stream } from '@effection/subscription';
   close(...args: TClose extends undefined ? [] : [TClose]): void;
+  stream: Stream<T, TClose>;
 }
@@ -34,3 +35,5 @@
 
-  return Object.assign(subscribable, {
+  return Object.assign({
+    stream: subscribable,
+
     send(message: T) {
@@ -43,3 +46,3 @@ bus.emit('event', { done: false, value: message });
     }
-  });
+  }, subscribable);
 }

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

17215

increased by2.48%

Lines of code

146

increased by3.55%

No dependency changes