Compare commits

...

4 Commits

Author SHA1 Message Date
f548f4b6cb 3.0.38 2024-05-17 19:21:34 +02:00
23a7a77a73 fix(core): update 2024-05-17 19:21:33 +02:00
13d2fc78b8 3.0.37 2024-05-17 18:40:33 +02:00
898cc0407d fix(core): update 2024-05-17 18:40:32 +02:00
4 changed files with 4720 additions and 2808 deletions

View File

@ -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",
"@push.rocks/smartfile": "^11.0.4",
"@push.rocks/tapbundle": "^5.0.17",
"@types/node": "^20.11.28"
"@git.zone/tstest": "^1.0.90",
"@push.rocks/smartfile": "^11.0.15",
"@push.rocks/tapbundle": "^5.0.23",
"@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"

7510
pnpm-lock.yaml generated

File diff suppressed because it is too large Load Diff

View File

@ -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.'
}

View File

@ -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;