3.0.38

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@push.rocks/smartstream",
-  "version": "3.0.36",
+  "version": "3.0.38",
   "private": false,
   "description": "A library to simplify the creation and manipulation of Node.js streams, providing utilities for handling transform, duplex, and readable/writable streams effectively in TypeScript.",
   "main": "dist_ts/index.js",
@@ -22,15 +22,15 @@
   },
   "homepage": "https://gitlab.com/push.rocks/smartstream#readme",
   "devDependencies": {
-    "@git.zone/tsbuild": "^2.1.72",
+    "@git.zone/tsbuild": "^2.1.80",
     "@git.zone/tsrun": "^1.2.44",
-    "@git.zone/tstest": "^1.0.88",
+    "@git.zone/tstest": "^1.0.90",
-    "@push.rocks/smartfile": "^11.0.4",
+    "@push.rocks/smartfile": "^11.0.15",
-    "@push.rocks/tapbundle": "^5.0.17",
+    "@push.rocks/tapbundle": "^5.0.23",
-    "@types/node": "^20.11.28"
+    "@types/node": "^20.12.12"
   },
   "dependencies": {
-    "@push.rocks/lik": "^6.0.14",
+    "@push.rocks/lik": "^6.0.15",
     "@push.rocks/smartpromise": "^4.0.3",
     "@push.rocks/smartrx": "^3.0.7",
     "@push.rocks/webstream": "^1.0.8"

ts/00_commitinfo_data.ts

@@ -3,6 +3,6 @@
  */
 export const commitinfo = {
   name: '@push.rocks/smartstream',
-  version: '3.0.36',
+  version: '3.0.38',
   description: 'A library to simplify the creation and manipulation of Node.js streams, providing utilities for handling transform, duplex, and readable/writable streams effectively in TypeScript.'
 }

ts/smartstream.classes.streamintake.ts

@@ -14,7 +14,7 @@ export class StreamIntake<T> extends plugins.stream.Readable {
   _read(size: number): void {
     // console.log('get next');
     const pushChunk = (): void => {
-      if (this.chunkStore.length > 0) {
+      while (this.chunkStore.length > 0) {
         // If push returns false, then we should stop reading
         if (!this.push(this.chunkStore.shift())) {
           return;