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;