From 7d16e3c80d7be80c99683634f207c1a31f08f7e1 Mon Sep 17 00:00:00 2001 From: smac89 Date: Sat, 5 Aug 2017 12:39:23 -0600 Subject: [PATCH] Fixed error with listening for other events --- types/merge2/index.d.ts | 6 +++++- types/merge2/merge2-tests.ts | 4 ++++ 2 files changed, 9 insertions(+), 1 deletion(-) diff --git a/types/merge2/index.d.ts b/types/merge2/index.d.ts index 0f503e48d1..f8c6ef88af 100644 --- a/types/merge2/index.d.ts +++ b/types/merge2/index.d.ts @@ -20,6 +20,9 @@ interface Merge2Stream extends NodeJS.ReadWriteStream { */ add(...args: Array): Merge2Stream; + on(event: string, listener: (...args: any[]) => void): this; + once(event: string, listener: (...args: any[]) => void): this; + /** * @summary It will emit 'queueDrain' when all streams merged. * If you set end === false in options, this event give you a notice that @@ -29,7 +32,8 @@ interface Merge2Stream extends NodeJS.ReadWriteStream { * * @return This stream */ - on(event: 'queueDrain', callback: () => void): this; + on(event: 'queueDrain', listener: () => void): this; + once(event: 'queueDrain', listener: () => void): this; } /** diff --git a/types/merge2/merge2-tests.ts b/types/merge2/merge2-tests.ts index 823ef8f389..69c8bdd6bd 100644 --- a/types/merge2/merge2-tests.ts +++ b/types/merge2/merge2-tests.ts @@ -32,6 +32,10 @@ stream.add(stream4, stream5); // .. stream.end(); +stream.on('data', (data: any) => { + console.log(data); +}); + // equal to merge2([stream1, stream2], stream3) stream = merge2(); stream.add([stream1, stream2]);