[node] stream: support readable/writableHWM for Duplex (#40843)

* stream: support readable/writableHWM for Duplex

see https://github.com/nodejs/node/commit/ef8ac7b5ac04aab3a96e0d6524c016afec321e5b and https://nodejs.org/api/stream.html#stream_new_stream_duplex_options

* [node] stream: support readable/writableHWM for Duplex (2)

Also for v8 and v9

* [node] stream: add tests for readable/writableHWM for Duplex (2)

* Revert "stream: support readable/writableHWM for Duplex" for v8, v9 and v11
This commit is contained in:
everhardt
2019-12-17 13:28:52 +00:00
committed by Orta
parent 06d5a6011b
commit dd4b4bf26c
4 changed files with 16 additions and 4 deletions
+2
View File
@@ -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;
+6 -2
View File
@@ -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
});
}
+6 -2
View File
@@ -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
});
}
+2
View File
@@ -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;