From 22df9dfd94c9e6373ff8ef7a358e670f49ffb2c2 Mon Sep 17 00:00:00 2001 From: Philipp Kunz Date: Mon, 13 Nov 2023 18:41:04 +0100 Subject: [PATCH] fix(core): update --- test/test.backpressure.ts | 3 --- ts/00_commitinfo_data.ts | 2 +- ts/smartstream.classes.smartduplex.ts | 1 - 3 files changed, 1 insertion(+), 5 deletions(-) diff --git a/test/test.backpressure.ts b/test/test.backpressure.ts index d071a47..a93ab49 100644 --- a/test/test.backpressure.ts +++ b/test/test.backpressure.ts @@ -7,7 +7,6 @@ tap.test('should run backpressure test', async (toolsArg) => { const stream1 = new SmartDuplex({ name: 'stream1', objectMode: true, - handleBackpressure: true, writeFunction: async (chunk, tools) => { await new Promise((resolve) => setTimeout(resolve, 10)); // Slow processing console.log(`processed chunk ${chunk} in stream 1`); @@ -17,7 +16,6 @@ tap.test('should run backpressure test', async (toolsArg) => { const stream2 = new SmartDuplex({ name: 'stream2', objectMode: true, - handleBackpressure: true, writeFunction: async (chunk, tools) => { await new Promise((resolve) => setTimeout(resolve, 20)); // Slow processing console.log(`processed chunk ${chunk} in stream 2`); @@ -27,7 +25,6 @@ tap.test('should run backpressure test', async (toolsArg) => { const stream3 = new SmartDuplex({ objectMode: true, name: 'stream3', - handleBackpressure: true, writeFunction: async (chunk, tools) => { await new Promise((resolve) => setTimeout(resolve, 100)); // Slow processing console.log(`processed chunk ${chunk} in stream 3`); diff --git a/ts/00_commitinfo_data.ts b/ts/00_commitinfo_data.ts index cadfcb7..3951350 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.22', + version: '3.0.23', description: 'simplifies access to node streams' } diff --git a/ts/smartstream.classes.smartduplex.ts b/ts/smartstream.classes.smartduplex.ts index 3b4b951..acf6282 100644 --- a/ts/smartstream.classes.smartduplex.ts +++ b/ts/smartstream.classes.smartduplex.ts @@ -17,7 +17,6 @@ export interface IStreamFinalFunction { export interface ISmartDuplexOptions extends DuplexOptions { debug?: boolean; name?: string; - handleBackpressure?: boolean; readFunction?: () => Promise; writeFunction?: IStreamWriteFunction; finalFunction?: IStreamFinalFunction;