stream: add trailing commas in stream source files

lib/.eslintrc.yaml

@@ -290,6 +290,7 @@ overrides:
       - ./internal/readme.md
       - ./internal/repl/history.js
       - ./internal/source_map/prepare_stack_trace.js
+      - ./internal/streams/*.js
       - ./internal/structured_clone.js
       - ./internal/test/*.js
       - ./internal/test_runner/**/*.js

lib/internal/streams/buffer_list.js

@@ -175,7 +175,7 @@ module.exports = class BufferList {
       // Only inspect one level.
       depth: 0,
       // It should not recurse.
-      customInspect: false
+      customInspect: false,
     });
   }
 };

lib/internal/streams/destroy.js

@@ -14,7 +14,7 @@ const {
   kDestroyed,
   isDestroyed,
   isFinished,
-  isServerRequest
+  isServerRequest,
 } = require('internal/streams/utils');
 
 const kDestroy = Symbol('kDestroy');
@@ -334,5 +334,5 @@ module.exports = {
   destroyer,
   destroy,
   undestroy,
-  errorOrDestroy
+  errorOrDestroy,
 };

lib/internal/streams/duplex.js

@@ -114,8 +114,8 @@ ObjectDefineProperties(Duplex.prototype, {
         this._readableState.destroyed = value;
         this._writableState.destroyed = value;
       }
-    }
-  }
+    },
+  },
 });
 
 let webStreamsAdapters;

lib/internal/streams/duplexify.js

@@ -32,7 +32,7 @@ const {
 const { AbortController } = require('internal/abort_controller');
 
 const {
-  FunctionPrototypeCall
+  FunctionPrototypeCall,
 } = primordials;
 
 // This is needed for pre node 17.
@@ -91,7 +91,7 @@ module.exports = function duplexify(body, name) {
         objectMode: true,
         write,
         final,
-        destroy
+        destroy,
       });
     }
 
@@ -127,7 +127,7 @@ module.exports = function duplexify(body, name) {
             }
           });
         },
-        destroy
+        destroy,
       });
     }
 
@@ -143,7 +143,7 @@ module.exports = function duplexify(body, name) {
     return from(Duplexify, body, {
       // TODO (ronag): highWaterMark?
       objectMode: true,
-      writable: false
+      writable: false,
     });
   }
 
@@ -192,7 +192,7 @@ module.exports = function duplexify(body, name) {
     return d = new Duplexify({
       objectMode: true,
       writable: false,
-      read() {}
+      read() {},
     });
   }
 
@@ -236,7 +236,7 @@ function fromAsyncGen(fn) {
     destroy(err, cb) {
       ac.abort();
       cb(err);
-    }
+    },
   };
 }
 

lib/internal/streams/end-of-stream.js

@@ -9,7 +9,7 @@ const {
 } = require('internal/errors');
 const {
   ERR_INVALID_ARG_TYPE,
-  ERR_STREAM_PREMATURE_CLOSE
+  ERR_STREAM_PREMATURE_CLOSE,
 } = codes;
 const {
   kEmptyObject,
@@ -19,7 +19,7 @@ const {
   validateAbortSignal,
   validateFunction,
   validateObject,
-  validateBoolean
+  validateBoolean,
 } = require('internal/validators');
 
 const { Promise, PromisePrototypeThen } = primordials;

lib/internal/streams/from.js

@@ -9,7 +9,7 @@ const { Buffer } = require('buffer');
 
 const {
   ERR_INVALID_ARG_TYPE,
-  ERR_STREAM_NULL_VALUES
+  ERR_STREAM_NULL_VALUES,
 } = require('internal/errors').codes;
 
 function from(Readable, iterable, opts) {
@@ -21,7 +21,7 @@ function from(Readable, iterable, opts) {
       read() {
         this.push(iterable);
         this.push(null);
-      }
+      },
     });
   }
 

lib/internal/streams/lazy_transform.js

@@ -12,7 +12,7 @@ const {
 const stream = require('stream');
 
 const {
-  getDefaultEncoding
+  getDefaultEncoding,
 } = require('internal/crypto/util');
 
 module.exports = LazyTransform;
@@ -43,7 +43,7 @@ function makeSetter(name) {
       value: val,
       enumerable: true,
       configurable: true,
-      writable: true
+      writable: true,
     });
   };
 }
@@ -54,13 +54,13 @@ ObjectDefineProperties(LazyTransform.prototype, {
     get: makeGetter('_readableState'),
     set: makeSetter('_readableState'),
     configurable: true,
-    enumerable: true
+    enumerable: true,
   },
   _writableState: {
     __proto__: null,
     get: makeGetter('_writableState'),
     set: makeSetter('_writableState'),
     configurable: true,
-    enumerable: true
-  }
+    enumerable: true,
+  },
 });

lib/internal/streams/pipeline.js

@@ -27,7 +27,7 @@ const {
 
 const {
   validateFunction,
-  validateAbortSignal
+  validateAbortSignal,
 } = require('internal/validators');
 
 const {
@@ -60,7 +60,7 @@ function destroyer(stream, reading, writing) {
       finished = true;
       destroyImpl.destroyer(stream, err || new ERR_STREAM_DESTROYED('pipe'));
     },
-    cleanup
+    cleanup,
   };
 }
 
@@ -314,7 +314,7 @@ function pipelineImpl(streams, callback, opts) {
         // composed through `.pipe(stream)`.
 
         const pt = new PassThrough({
-          objectMode: true
+          objectMode: true,
         });
 
         // Handle Promises/A+ spec, `then` could be a getter that throws on

lib/internal/streams/readable.js

@@ -32,7 +32,7 @@ const {
   Promise,
   SafeSet,
   SymbolAsyncIterator,
-  Symbol
+  Symbol,
 } = primordials;
 
 module.exports = Readable;
@@ -54,7 +54,7 @@ const BufferList = require('internal/streams/buffer_list');
 const destroyImpl = require('internal/streams/destroy');
 const {
   getHighWaterMark,
-  getDefaultHighWaterMark
+  getDefaultHighWaterMark,
 } = require('internal/streams/state');
 
 const {
@@ -65,8 +65,8 @@ const {
     ERR_OUT_OF_RANGE,
     ERR_STREAM_PUSH_AFTER_EOF,
     ERR_STREAM_UNSHIFT_AFTER_END_EVENT,
-    ERR_UNKNOWN_ENCODING
-  }
+    ERR_UNKNOWN_ENCODING,
+  },
 } = require('internal/errors');
 const { validateObject } = require('internal/validators');
 
@@ -1174,15 +1174,15 @@ ObjectDefineProperties(Readable.prototype, {
       if (this._readableState) {
         this._readableState.readable = !!val;
       }
-    }
+    },
   },
 
   readableDidRead: {
     __proto__: null,
     enumerable: false,
     get: function() {
       return this._readableState.dataEmitted;
-    }
+    },
   },
 
   readableAborted: {
@@ -1194,23 +1194,23 @@ ObjectDefineProperties(Readable.prototype, {
         (this._readableState.destroyed || this._readableState.errored) &&
         !this._readableState.endEmitted
       );
-    }
+    },
   },
 
   readableHighWaterMark: {
     __proto__: null,
     enumerable: false,
     get: function() {
       return this._readableState.highWaterMark;
-    }
+    },
   },
 
   readableBuffer: {
     __proto__: null,
     enumerable: false,
     get: function() {
       return this._readableState && this._readableState.buffer;
-    }
+    },
   },
 
   readableFlowing: {
@@ -1223,46 +1223,46 @@ ObjectDefineProperties(Readable.prototype, {
       if (this._readableState) {
         this._readableState.flowing = state;
       }
-    }
+    },
   },
 
   readableLength: {
     __proto__: null,
     enumerable: false,
     get() {
       return this._readableState.length;
-    }
+    },
   },
 
   readableObjectMode: {
     __proto__: null,
     enumerable: false,
     get() {
       return this._readableState ? this._readableState.objectMode : false;
-    }
+    },
   },
 
   readableEncoding: {
     __proto__: null,
     enumerable: false,
     get() {
       return this._readableState ? this._readableState.encoding : null;
-    }
+    },
   },
 
   errored: {
     __proto__: null,
     enumerable: false,
     get() {
       return this._readableState ? this._readableState.errored : null;
-    }
+    },
   },
 
   closed: {
     __proto__: null,
     get() {
       return this._readableState ? this._readableState.closed : false;
-    }
+    },
   },
 
   destroyed: {
@@ -1281,15 +1281,15 @@ ObjectDefineProperties(Readable.prototype, {
       // Backward compatibility, the user is explicitly
       // managing destroyed.
       this._readableState.destroyed = value;
-    }
+    },
   },
 
   readableEnded: {
     __proto__: null,
     enumerable: false,
     get() {
       return this._readableState ? this._readableState.endEmitted : false;
-    }
+    },
   },
 
 });
@@ -1300,7 +1300,7 @@ ObjectDefineProperties(ReadableState.prototype, {
     __proto__: null,
     get() {
       return this.pipes.length;
-    }
+    },
   },
 
   // Legacy property for `paused`.
@@ -1311,8 +1311,8 @@ ObjectDefineProperties(ReadableState.prototype, {
     },
     set(value) {
       this[kPaused] = !!value;
-    }
-  }
+    },
+  },
 });
 
 // Exposed for testing purposes only.
@@ -1426,6 +1426,6 @@ Readable.wrap = function(src, options) {
     destroy(err, callback) {
       destroyImpl.destroyer(src, err);
       callback(err);
-    }
+    },
   }).wrap(src);
 };

lib/internal/streams/state.js

@@ -32,5 +32,5 @@ function getHighWaterMark(state, options, duplexKey, isDuplex) {
 
 module.exports = {
   getHighWaterMark,
-  getDefaultHighWaterMark
+  getDefaultHighWaterMark,
 };

lib/internal/streams/transform.js

@@ -70,7 +70,7 @@ const {
 
 module.exports = Transform;
 const {
-  ERR_METHOD_NOT_IMPLEMENTED
+  ERR_METHOD_NOT_IMPLEMENTED,
 } = require('internal/errors').codes;
 const Duplex = require('internal/streams/duplex');
 const { getHighWaterMark } = require('internal/streams/state');
@@ -99,7 +99,7 @@ function Transform(options) {
       // a "bug" where we check needDrain before calling _write and not after.
       // Refs: https://github.com/nodejs/node/pull/32887
       // Refs: https://github.com/nodejs/node/pull/35941
-      writableHighWaterMark: options.writableHighWaterMark || 0
+      writableHighWaterMark: options.writableHighWaterMark || 0,
     };
   }