@effection/channel - npm Package Compare versions

Comparing version 2.0.4 to 2.0.5

CHANGELOG.md

 # Changelog
 
+## \[2.0.5]
+
+### Dependencies
+
+- Updated to latest `@effection/core`
+
 ## \[2.0.4]
@@ -4,0 +10,0 @@

dist-cjs/channel.d.ts

@@ -5,11 +5,11 @@ import { WritableStream, Writable, Stream } from '@effection/stream';
  */
-export declare type Close<T> = (...args: T extends undefined ? [] : [T]) => void;
+export type Close<T> = (...args: T extends undefined ? [] : [T]) => void;
 /**
  * @hidden
  */
-export declare type Send<T> = Writable<T>['send'];
+export type Send<T> = Writable<T>['send'];
 /**
  * Options which can be provided when creating a {@link Channel} via {@link createChannel}.
  */
-export declare type ChannelOptions = {
+export type ChannelOptions = {
     /**
@@ -16,0 +16,0 @@ * The maximum number of subscribers that the channel should have. When this limit is exceeded

dist-cjs/channel.js

@@ -43,4 +43,4 @@ "use strict";
     }
-    let stream = stream_1.createStream((publish) => function* (task) {
-        let subscription = events_1.on(bus, 'event').subscribe(task);
+    let stream = (0, stream_1.createStream)((publish) => function* (task) {
+        let subscription = (0, events_1.on)(bus, 'event').subscribe(task);
         while (true) {
@@ -47,0 +47,0 @@ let { value: next } = yield subscription.next();

dist-cjs/index.js

 "use strict";
 var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
     if (k2 === undefined) k2 = k;
-    Object.defineProperty(o, k2, { enumerable: true, get: function() { return m[k]; } });
+    var desc = Object.getOwnPropertyDescriptor(m, k);
+    if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {
+      desc = { enumerable: true, get: function() { return m[k]; } };
+    }
+    Object.defineProperty(o, k2, desc);
 }) : (function(o, m, k, k2) {
@@ -6,0 +10,0 @@ if (k2 === undefined) k2 = k;

dist-esm/channel.d.ts

@@ -5,11 +5,11 @@ import { WritableStream, Writable, Stream } from '@effection/stream';
  */
-export declare type Close<T> = (...args: T extends undefined ? [] : [T]) => void;
+export type Close<T> = (...args: T extends undefined ? [] : [T]) => void;
 /**
  * @hidden
  */
-export declare type Send<T> = Writable<T>['send'];
+export type Send<T> = Writable<T>['send'];
 /**
  * Options which can be provided when creating a {@link Channel} via {@link createChannel}.
  */
-export declare type ChannelOptions = {
+export type ChannelOptions = {
     /**
@@ -16,0 +16,0 @@ * The maximum number of subscribers that the channel should have. When this limit is exceeded

package.json

 {
   "name": "@effection/channel",
-  "version": "2.0.4",
+  "version": "2.0.5",
   "description": "MPMC Channel implementation for effection",
@@ -30,10 +30,2 @@ "main": "dist-cjs/index.js",
   },
-  "devDependencies": {
-    "@frontside/tsconfig": "^1.2.0",
-    "@types/node": "^16.3.2",
-    "expect": "^25.4.0",
-    "mocha": "^8.3.1",
-    "ts-node": "^10.4.0",
-    "typescript": "^4.3.5"
-  },
   "volta": {
@@ -43,6 +35,6 @@ "extends": "../../package.json"
   "dependencies": {
-    "@effection/core": "2.2.1",
-    "@effection/events": "2.0.4",
-    "@effection/stream": "2.0.4"
+    "@effection/core": "2.2.2",
+    "@effection/events": "2.0.5",
+    "@effection/stream": "2.0.5"
   }
 }

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

34156

increased by0.12%

Dev dependency count

0

decreased by-100%

Lines of code

353

increased by1.15%

Dependency changes

• + Added@chainsafe/abort-controller@3.0.1(transitive)

• + Added@effection/core@2.2.2(transitive)

• + Added@effection/events@2.0.5(transitive)

• + Added@effection/stream@2.0.5(transitive)

• + Added@effection/subscription@2.0.5(transitive)

• - Removed@effection/core@2.2.1(transitive)

• - Removed@effection/events@2.0.4(transitive)

• - Removed@effection/stream@2.0.4(transitive)

• - Removed@effection/subscription@2.0.4(transitive)

• - Removedabort-controller@3.0.0(transitive)

• Updated@effection/core@2.2.2

• Updated@effection/events@2.0.5

• Updated@effection/stream@2.0.5