mirror of https://github.com/nodejs/node.git
stream: use for...of
PR-URL: https://github.com/nodejs/node/pull/30960 Reviewed-By: Matteo Collina <matteo.collina@gmail.com> Reviewed-By: Luigi Pinca <luigipinca@gmail.com> Reviewed-By: Anna Henningsen <anna@addaleax.net> Reviewed-By: Rich Trott <rtrott@gmail.com> Reviewed-By: Ruben Bridgewater <ruben@bridgewater.de> Reviewed-By: Michaël Zasso <targos@protonmail.com> Reviewed-By: James M Snell <jasnell@gmail.com>
This commit is contained in:
parent
6859fcf6f7
commit
ce49f90e14
|
@ -42,9 +42,7 @@ ObjectSetPrototypeOf(Duplex, Readable);
|
|||
|
||||
{
|
||||
// Allow the keys array to be GC'ed.
|
||||
const keys = ObjectKeys(Writable.prototype);
|
||||
for (let v = 0; v < keys.length; v++) {
|
||||
const method = keys[v];
|
||||
for (const method of ObjectKeys(Writable.prototype)) {
|
||||
if (!Duplex.prototype[method])
|
||||
Duplex.prototype[method] = Writable.prototype[method];
|
||||
}
|
||||
|
|
|
@ -877,8 +877,8 @@ Readable.prototype.unpipe = function(dest) {
|
|||
state.pipes = [];
|
||||
state.flowing = false;
|
||||
|
||||
for (var i = 0; i < dests.length; i++)
|
||||
dests[i].emit('unpipe', this, { hasUnpiped: false });
|
||||
for (const dest of dests)
|
||||
dest.emit('unpipe', this, { hasUnpiped: false });
|
||||
return this;
|
||||
}
|
||||
|
||||
|
@ -1082,8 +1082,8 @@ Readable.prototype.wrap = function(stream) {
|
|||
}
|
||||
|
||||
// Proxy certain important events.
|
||||
for (var n = 0; n < kProxyEvents.length; n++) {
|
||||
stream.on(kProxyEvents[n], this.emit.bind(this, kProxyEvents[n]));
|
||||
for (const kProxyEvent of kProxyEvents) {
|
||||
stream.on(kProxyEvent, this.emit.bind(this, kProxyEvent));
|
||||
}
|
||||
|
||||
// When we try to consume some more bytes, simply unpause the
|
||||
|
|
Loading…
Reference in New Issue