@effection/channel - npm Package Compare versions

Comparing version 0.6.1-3cde29a to 0.6.1-b1952e1

dist/channel.d.ts

@@ -9,2 +9,3 @@ import { Operation } from 'effection';
     subscribe(): Operation<Subscription<T, void>>;
+    close(): void;
 }

dist/channel.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.Channel = void 0;
+const effection_1 = require("effection");
 const subscription_1 = require("@effection/subscription");
@@ -21,6 +22,15 @@ const events_1 = require("@effection/events");
     subscribe() {
-        return subscription_1.Subscribable.from(events_1.on(this.bus, 'message')).map(([message]) => message)[subscription_1.SymbolSubscribable]();
+        let { bus } = this;
+        return subscription_1.createSubscription(function* (publish) {
+            yield effection_1.spawn(subscription_1.forEach(events_1.on(bus, 'message'), function* ([message]) {
+                publish(message);
+            }));
+            yield events_1.once(bus, 'close');
+        });
     }
+    close() {
+        this.bus.emit('close');
+    }
 }
 exports.Channel = Channel;
 //# sourceMappingURL=channel.js.map

package.json

 {
   "name": "@effection/channel",
-  "version": "0.6.1-3cde29a",
+  "version": "0.6.1-b1952e1",
   "description": "MPMC Channel implementation for effection",
@@ -5,0 +5,0 @@ "main": "dist/index.js",

Fixed alerts

Major refactor

Supply chain risk

Package has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

5253

increased by10.8%

Lines of code

49

increased by28.95%

Number of medium supply chain risk alerts

0

decreased by-100%

No dependency changes