@thi.ng/rstream - npm Package Compare versions

Comparing version 8.4.3 to 8.5.0

async.js

@@ -9,4 +9,3 @@ import { SEMAPHORE } from "@thi.ng/api/api";
       for await (let x of src) {
-        if (!active)
-          return;
+        if (!active) return;
         $stream.next(x);
@@ -35,4 +34,3 @@ }
         initial = void 0;
-      } else
-        promises.push(Promise.resolve(x));
+      } else promises.push(Promise.resolve(x));
     },
@@ -43,4 +41,3 @@ done() {
         initial = void 0;
-      } else
-        promises.push(Promise.resolve(SEMAPHORE));
+      } else promises.push(Promise.resolve(SEMAPHORE));
     }
@@ -50,6 +47,4 @@ });
     const res = await promises.shift();
-    if (res === SEMAPHORE)
-      break;
-    if (!promises.length)
-      promises[0] = $newInitial();
+    if (res === SEMAPHORE) break;
+    if (!promises.length) promises[0] = $newInitial();
     yield res;
@@ -56,0 +51,0 @@ }

CHANGELOG.md

 # Change Log
 
-- **Last updated**: 2024-04-23T07:02:18Z
+- **Last updated**: 2024-05-08T18:24:31Z
 - **Generator**: [thi.ng/monopub](https://thi.ng/monopub)
@@ -12,2 +12,9 @@
 
+## [8.5.0](https://github.com/thi-ng/umbrella/tree/@thi.ng/rstream@8.5.0) (2024-05-08)
+
+#### 🚀 Features
+
+- add rdom-klist example project, update readmes ([cd458ac](https://github.com/thi-ng/umbrella/commit/cd458ac))
+- add rdom-klist example project, update readmes ([531437f](https://github.com/thi-ng/umbrella/commit/531437f))
+
 ### [8.4.1](https://github.com/thi-ng/umbrella/tree/@thi.ng/rstream@8.4.1) (2024-04-20)
@@ -14,0 +21,0 @@

package.json

 {
   "name": "@thi.ng/rstream",
-  "version": "8.4.3",
+  "version": "8.5.0",
   "description": "Reactive streams & subscription primitives for constructing dataflow graphs / pipelines",
@@ -43,16 +43,16 @@ "type": "module",
   "dependencies": {
-    "@thi.ng/api": "^8.11.1",
-    "@thi.ng/arrays": "^2.9.5",
-    "@thi.ng/associative": "^6.3.59",
-    "@thi.ng/atom": "^5.2.45",
-    "@thi.ng/checks": "^3.6.3",
-    "@thi.ng/errors": "^2.5.6",
-    "@thi.ng/logger": "^3.0.11",
-    "@thi.ng/transducers": "^9.0.4"
+    "@thi.ng/api": "^8.11.2",
+    "@thi.ng/arrays": "^2.9.6",
+    "@thi.ng/associative": "^6.3.60",
+    "@thi.ng/atom": "^5.3.0",
+    "@thi.ng/checks": "^3.6.4",
+    "@thi.ng/errors": "^2.5.7",
+    "@thi.ng/logger": "^3.0.12",
+    "@thi.ng/transducers": "^9.0.5"
   },
   "devDependencies": {
-    "@microsoft/api-extractor": "^7.43.0",
-    "esbuild": "^0.20.2",
-    "typedoc": "^0.25.12",
-    "typescript": "^5.4.3"
+    "@microsoft/api-extractor": "^7.43.2",
+    "esbuild": "^0.21.1",
+    "typedoc": "^0.25.13",
+    "typescript": "^5.4.5"
   },
@@ -222,3 +222,3 @@ "keywords": [
   },
-  "gitHead": "aed3421c21044c005fbcb7cc37965ccf85a870d2\n"
+  "gitHead": "df34b4a9e650cc7323575356de207d78933bdcf3\n"
 }

raf.js

@@ -12,4 +12,3 @@ import { isNode } from "@thi.ng/checks/is-node";
     if (opts.timestamp && opts.t0) {
-      if (t0 === void 0)
-        t0 = time;
+      if (t0 === void 0) t0 = time;
       time -= t0;
@@ -16,0 +15,0 @@ }

README.md

@@ -217,3 +217,3 @@ <!-- This file is generated - DO NOT EDIT! -->
 
-Package sizes (brotli'd, pre-treeshake): ESM: 6.32 KB
+Package sizes (brotli'd, pre-treeshake): ESM: 6.33 KB
 
@@ -269,2 +269,3 @@ ## Dependencies
 | <img src="https://raw.githubusercontent.com/thi-ng/umbrella/develop/assets/examples/rdom-key-sequences.jpg" width="240"/>            | rstream & transducer-based FSM for converting key event sequences into high-level commands              | [Demo](https://demo.thi.ng/umbrella/rdom-key-sequences/)   | [Source](https://github.com/thi-ng/umbrella/tree/develop/examples/rdom-key-sequences)  |
+| <img src="https://raw.githubusercontent.com/thi-ng/umbrella/develop/assets/examples/rdom-klist.png" width="240"/>                    | Basic usage of thi.ng/rdom keyed list component wrapper                                                 | [Demo](https://demo.thi.ng/umbrella/rdom-klist/)           | [Source](https://github.com/thi-ng/umbrella/tree/develop/examples/rdom-klist)          |
 | <img src="https://raw.githubusercontent.com/thi-ng/umbrella/develop/assets/examples/rdom-lissajous.png" width="240"/>                | rdom & hiccup-canvas interop test                                                                       | [Demo](https://demo.thi.ng/umbrella/rdom-lissajous/)       | [Source](https://github.com/thi-ng/umbrella/tree/develop/examples/rdom-lissajous)      |
@@ -271,0 +272,0 @@ |                                                                                                                                      | Full umbrella repo doc string search w/ paginated results                                               | [Demo](https://demo.thi.ng/umbrella/rdom-search-docs/)     | [Source](https://github.com/thi-ng/umbrella/tree/develop/examples/rdom-search-docs)    |

stream.js

@@ -60,4 +60,3 @@ import { isFunction } from "@thi.ng/checks/is-function";
   error(e) {
-    if (super.error(e))
-      return true;
+    if (super.error(e)) return true;
     this.cancel();
@@ -64,0 +63,0 @@ return false;

subscription.js

@@ -124,4 +124,3 @@ import { SEMAPHORE } from "@thi.ng/api/api";
   next(x) {
-    if (this.state >= State.DONE)
-      return;
+    if (this.state >= State.DONE) return;
     this.xform ? this.dispatchXform(x) : this.dispatch(x);
@@ -131,7 +130,5 @@ }
     LOGGER.debug(this.id, "entering done()");
-    if (this.state >= State.DONE)
-      return;
+    if (this.state >= State.DONE) return;
     if (this.xform) {
-      if (!this.dispatchXformDone())
-        return;
+      if (!this.dispatchXformDone()) return;
     }
@@ -166,4 +163,3 @@ this.state = State.DONE;
       } catch (e) {
-        if (!this.error(e))
-          return false;
+        if (!this.error(e)) return false;
       }
@@ -170,0 +166,0 @@ }

sync-raf.js

@@ -13,9 +13,7 @@ import { isNode } from "@thi.ng/checks/is-node";
   next(x) {
-    if (this.state >= State.DONE)
-      return;
+    if (this.state >= State.DONE) return;
     this.queued = x;
     if (!this.raf) {
       const update = () => {
-        if (this.state < State.DONE)
-          super.next(this.queued);
+        if (this.state < State.DONE) super.next(this.queued);
         this._clean();
@@ -22,0 +20,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

Improved metrics

Total package byte prevSize

245764

increased by0.26%

Number of lines in readme file

1017

increased by0.1%

Worsened metrics

Lines of code

3935

decreased by-0.33%

Dependency changes

• [e-mail]/api@^8.11.2

• [e-mail]/arrays@^2.9.6

• [e-mail]/associative@^6.3.60

• [e-mail]/atom@^5.3.0

• [e-mail]/checks@^3.6.4

• [e-mail]/errors@^2.5.7

• [e-mail]/logger@^3.0.12

• [e-mail]/transducers@^9.0.5