3.0.37

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@push.rocks/smartstream",
-  "version": "3.0.36",
+  "version": "3.0.37",
   "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",

ts/00_commitinfo_data.ts

@@ -3,6 +3,6 @@
  */
 export const commitinfo = {
   name: '@push.rocks/smartstream',
-  version: '3.0.36',
+  version: '3.0.37',
   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;