From 898cc0407dee139a75c4326d1938dd81a8f6fab9 Mon Sep 17 00:00:00 2001 From: Philipp Kunz Date: Fri, 17 May 2024 18:40:32 +0200 Subject: [PATCH] fix(core): update --- ts/00_commitinfo_data.ts | 2 +- ts/smartstream.classes.streamintake.ts | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/ts/00_commitinfo_data.ts b/ts/00_commitinfo_data.ts index 942be9f..445da27 100644 --- a/ts/00_commitinfo_data.ts +++ b/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.' } diff --git a/ts/smartstream.classes.streamintake.ts b/ts/smartstream.classes.streamintake.ts index 2feb5e9..99f10ad 100644 --- a/ts/smartstream.classes.streamintake.ts +++ b/ts/smartstream.classes.streamintake.ts @@ -14,7 +14,7 @@ export class StreamIntake 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;