@effection/stream - npm Package Compare versions

Comparing version 2.0.0-beta.2 to 2.0.0-beta.3

CHANGELOG.md

 # Changelog
 
+## \[2.0.0-beta.3]
+
+- Stream `buffer` returns the actual buffer and gives direct access to it
+  - [07c8f83](https://github.com/thefrontside/effection/commit/07c8f83b5968f347ca72795c447be411e66274ed) Stream `buffer` returns the actual buffer on 2021-09-30
+
 ## \[2.0.0-beta.2]
@@ -4,0 +9,0 @@

dist-cjs/stream.d.ts

@@ -19,5 +19,5 @@ import { Subscription } from '@effection/subscription';
     subscribe(scope: Task): Subscription<T, TReturn>;
-    buffer(limit?: number): Resource<Stream<T, TReturn>>;
+    buffer(limit?: number): Resource<Iterable<T>>;
 }
 export declare function createStream<T, TReturn = undefined>(callback: Callback<T, TReturn>, name?: string): Stream<T, TReturn>;
 //# sourceMappingURL=stream.d.ts.map

dist-cjs/stream.js

@@ -70,11 +70,7 @@ "use strict";
             return {
+                name: `${name}.buffer(${limit})`,
                 *init() {
                     let buffer = buffer_1.createBuffer(limit);
                     yield core_1.spawn(stream.forEach((value) => { buffer.push(value); }));
-                    return createStream((publish) => function* () {
-                        for (let value of buffer) {
-                            publish(value);
-                        }
-                        return yield stream.forEach(publish);
-                    });
+                    return buffer;
                 }
@@ -81,0 +77,0 @@ };

dist-esm/stream.d.ts

@@ -19,5 +19,5 @@ import { Subscription } from '@effection/subscription';
     subscribe(scope: Task): Subscription<T, TReturn>;
-    buffer(limit?: number): Resource<Stream<T, TReturn>>;
+    buffer(limit?: number): Resource<Iterable<T>>;
 }
 export declare function createStream<T, TReturn = undefined>(callback: Callback<T, TReturn>, name?: string): Stream<T, TReturn>;
 //# sourceMappingURL=stream.d.ts.map

dist-esm/stream.js

@@ -67,11 +67,7 @@ import { createQueue } from '@effection/subscription';
             return {
+                name: `${name}.buffer(${limit})`,
                 *init() {
                     let buffer = createBuffer(limit);
                     yield spawn(stream.forEach((value) => { buffer.push(value); }));
-                    return createStream((publish) => function* () {
-                        for (let value of buffer) {
-                            publish(value);
-                        }
-                        return yield stream.forEach(publish);
-                    });
+                    return buffer;
                 }
@@ -78,0 +74,0 @@ };

package.json

 {
   "name": "@effection/stream",
-  "version": "2.0.0-beta.2",
+  "version": "2.0.0-beta.3",
   "description": "Effection Stream",
@@ -5,0 +5,0 @@ "main": "dist-cjs/index.js",

src/stream.ts

@@ -23,3 +23,3 @@ import { createQueue, Subscription } from '@effection/subscription';
   subscribe(scope: Task): Subscription<T, TReturn>;
-  buffer(limit?: number): Resource<Stream<T, TReturn>>;
+  buffer(limit?: number): Resource<Iterable<T>>;
 }
@@ -102,4 +102,5 @@
 
-    buffer(limit = Infinity): Resource<Stream<T, TReturn>> {
+    buffer(limit = Infinity): Resource<Iterable<T>> {
       return {
+        name: `${name}.buffer(${limit})`,
         *init() {
@@ -110,8 +111,3 @@ let buffer = createBuffer<T>(limit);
 
-          return createStream<T, TReturn>((publish) => function*() {
-            for(let value of buffer) {
-              publish(value);
-            }
-            return yield stream.forEach(publish);
-          });
+          return buffer;
         }
@@ -118,0 +114,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

35009

decreased by-1.7%

Lines of code

476

decreased by-2.46%

No dependency changes