diff --git a/types/node/stream.d.ts b/types/node/stream.d.ts index 2a0895b0dc..a271af89cd 100644 --- a/types/node/stream.d.ts +++ b/types/node/stream.d.ts @@ -210,6 +210,8 @@ declare module "stream" { allowHalfOpen?: boolean; readableObjectMode?: boolean; writableObjectMode?: boolean; + readableHighWaterMark?: number; + writableHighWaterMark?: number; read?(this: Duplex, size: number): void; write?(this: Duplex, chunk: any, encoding: string, callback: (error?: Error | null) => void): void; writev?(this: Duplex, chunks: Array<{ chunk: any, encoding: string }>, callback: (error?: Error | null) => void): void; diff --git a/types/node/test/stream.ts b/types/node/test/stream.ts index 892f5a0fca..b62c7d5aec 100644 --- a/types/node/test/stream.ts +++ b/types/node/test/stream.ts @@ -96,7 +96,9 @@ function simplified_stream_ctor_test() { cb; }, readableObjectMode: true, - writableObjectMode: true + writableObjectMode: true, + readableHighWaterMark: 2048, + writableHighWaterMark: 1024 }); new Transform({ @@ -154,7 +156,9 @@ function simplified_stream_ctor_test() { }, allowHalfOpen: true, readableObjectMode: true, - writableObjectMode: true + writableObjectMode: true, + readableHighWaterMark: 2048, + writableHighWaterMark: 1024 }); } diff --git a/types/node/v10/node-tests.ts b/types/node/v10/node-tests.ts index 89372fee3b..0a73d8cda7 100644 --- a/types/node/v10/node-tests.ts +++ b/types/node/v10/node-tests.ts @@ -1147,7 +1147,9 @@ function simplified_stream_ctor_test() { cb; }, readableObjectMode: true, - writableObjectMode: true + writableObjectMode: true, + readableHighWaterMark: 2048, + writableHighWaterMark: 1024 }); new stream.Transform({ @@ -1205,7 +1207,9 @@ function simplified_stream_ctor_test() { }, allowHalfOpen: true, readableObjectMode: true, - writableObjectMode: true + writableObjectMode: true, + readableHighWaterMark: 2048, + writableHighWaterMark: 1024 }); } diff --git a/types/node/v10/stream.d.ts b/types/node/v10/stream.d.ts index f8090aedb8..f3fd17dbac 100644 --- a/types/node/v10/stream.d.ts +++ b/types/node/v10/stream.d.ts @@ -195,6 +195,8 @@ declare module "stream" { allowHalfOpen?: boolean; readableObjectMode?: boolean; writableObjectMode?: boolean; + readableHighWaterMark?: number; + writableHighWaterMark?: number; read?(this: Duplex, size: number): void; write?(this: Duplex, chunk: any, encoding: string, callback: (error?: Error | null) => void): void; writev?(this: Duplex, chunks: Array<{ chunk: any, encoding: string }>, callback: (error?: Error | null) => void): void;