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;