push.rocks/smartstream
2
0
Fork 0
Code Issues 1 Pull Requests Packages Projects Releases Wiki Activity

fix(core): update

Browse Source
This commit is contained in:
Philipp Kunz 2023-11-11 20:44:00 +01:00
parent 3adb16d1f8
commit 465ccfec40
2 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
ts/00_commitinfo_data.ts
View File

@ -3,6 +3,6 @@
*/ */
export const commitinfo = { export const commitinfo = {
name: '@push.rocks/smartstream', name: '@push.rocks/smartstream',
version: '3.0.16', version: '3.0.17',
description: 'simplifies access to node streams' description: 'simplifies access to node streams'
} }

4
ts/smartstream.classes.smartduplex.ts
View File

@ -129,12 +129,15 @@ export class SmartDuplex<TInput = any, TOutput = any> extends Duplex {
} }
} }
public notBackpressured = true;
public push(chunkArg?: TOutput | null): boolean { public push(chunkArg?: TOutput | null): boolean {
const result = super.push(chunkArg); const result = super.push(chunkArg);
if (!result && this.handleBackpressure) { if (!result && this.handleBackpressure) {
this.notBackpressured = false;
this.pause(); this.pause();
// Listen for 'drain' event to resume // Listen for 'drain' event to resume
this.once('drain', () => { this.once('drain', () => {
this.notBackpressured = true;
this.resume(); // Resume the source of data this.resume(); // Resume the source of data
}); });
} }
@ -164,6 +167,7 @@ export class SmartDuplex<TInput = any, TOutput = any> extends Duplex {
} catch (err) { } catch (err) {
callback(err); callback(err);
} }
return this.notBackpressured;
} }
public async _final(callback: (error?: Error | null) => void) { public async _final(callback: (error?: Error | null) => void) {