@effection/stream - 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/match.d.ts

@@ -1,2 +0,2 @@
-export declare type DeepPartial<T> = {
+export type DeepPartial<T> = {
     [P in keyof T]?: DeepPartial<T[P]>;
@@ -3,0 +3,0 @@ };

dist-cjs/stream.d.ts

@@ -12,3 +12,3 @@ import { Subscription } from '@effection/subscription';
  */
-export declare type StreamCallback<T, TReturn> = (publish: (value: T) => void) => Operation<TReturn>;
+export type StreamCallback<T, TReturn> = (publish: (value: T) => void) => Operation<TReturn>;
 /**
@@ -15,0 +15,0 @@ * A `Stream` of values. A `Stream` can be subscribed to, which creates an

dist-cjs/stream.js

@@ -43,3 +43,3 @@ "use strict";
     let subscribe = (task) => {
-        let queue = subscription_1.createQueue(name);
+        let queue = (0, subscription_1.createQueue)(name);
         task.run(function* () {
@@ -67,3 +67,3 @@ let result = yield callback(queue.send);
         match(reference) {
-            return stream.filter(match_1.matcher(reference));
+            return stream.filter((0, match_1.matcher)(reference));
         },
@@ -107,4 +107,4 @@ grep(search) {
                 *init() {
-                    let buffer = buffer_1.createBuffer(limit);
-                    yield core_1.spawn(stream.forEach((value) => { buffer.push(value); }));
+                    let buffer = (0, buffer_1.createBuffer)(limit);
+                    yield (0, core_1.spawn)(stream.forEach((value) => { buffer.push(value); }));
                     return buffer;
@@ -111,0 +111,0 @@ }

dist-cjs/writable-stream.d.ts

@@ -11,3 +11,3 @@ import { Stream } from './stream';
  */
-export declare type WritableStream<TReceive, TSend, TReturn = undefined> = Stream<TReceive, TReturn> & Writable<TSend>;
+export type WritableStream<TReceive, TSend, TReturn = undefined> = Stream<TReceive, TReturn> & Writable<TSend>;
 //# sourceMappingURL=writable-stream.d.ts.map

dist-esm/match.d.ts

@@ -1,2 +0,2 @@
-export declare type DeepPartial<T> = {
+export type DeepPartial<T> = {
     [P in keyof T]?: DeepPartial<T[P]>;
@@ -3,0 +3,0 @@ };

dist-esm/stream.d.ts

@@ -12,3 +12,3 @@ import { Subscription } from '@effection/subscription';
  */
-export declare type StreamCallback<T, TReturn> = (publish: (value: T) => void) => Operation<TReturn>;
+export type StreamCallback<T, TReturn> = (publish: (value: T) => void) => Operation<TReturn>;
 /**
@@ -15,0 +15,0 @@ * A `Stream` of values. A `Stream` can be subscribed to, which creates an

dist-esm/writable-stream.d.ts

@@ -11,3 +11,3 @@ import { Stream } from './stream';
  */
-export declare type WritableStream<TReceive, TSend, TReturn = undefined> = Stream<TReceive, TReturn> & Writable<TSend>;
+export type WritableStream<TReceive, TSend, TReturn = undefined> = Stream<TReceive, TReturn> & Writable<TSend>;
 //# sourceMappingURL=writable-stream.d.ts.map

package.json

 {
   "name": "@effection/stream",
-  "version": "2.0.4",
+  "version": "2.0.5",
   "description": "Effection Stream",
@@ -31,13 +31,5 @@ "main": "dist-cjs/index.js",
   "dependencies": {
-    "@effection/core": "2.2.1",
-    "@effection/subscription": "2.0.4"
+    "@effection/core": "2.2.2",
+    "@effection/subscription": "2.0.5"
   },
-  "devDependencies": {
-    "@frontside/tsconfig": "^1.2.0",
-    "@types/mocha": "^8.0.3",
-    "expect": "^25.4.0",
-    "mocha": "^8.3.1",
-    "ts-node": "^10.4.0",
-    "typescript": "^4.3.5"
-  },
   "volta": {
@@ -44,0 +36,0 @@ "extends": "../../package.json"

src/stream.ts

@@ -338,3 +338,3 @@ import { createQueue, Subscription } from '@effection/subscription';
     task.run(function*() {
-      let result = yield callback(queue.send);
+      let result: TReturn = yield callback(queue.send);
       queue.closeWith(result);
@@ -341,0 +341,0 @@ }, { labels: { name: 'publisher', expand: false } });

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

Dev dependency count

0

decreased by-100%

Worsened metrics

Total package byte prevSize

73899

decreased by-0.14%

Dependency changes

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

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

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

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

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

• - Removedabort-controller@3.0.0(transitive)

• Updated@effection/core@2.2.2

• Updated@effection/subscription@2.0.5