stream: add trailing commas in stream source files

PR-URL: #46686 Reviewed-By: Robert Nagy <[email protected]> Reviewed-By: Moshe Atlow <[email protected]> Reviewed-By: Matteo Collina <[email protected]> Reviewed-By: Darshan Sen <[email protected]>

Author: aduh95

lib/.eslintrc.yaml

@@ -278,6 +278,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');
 
 constkDestroy=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;
 }
-}
-}
+},
+},
 });
 
 letwebStreamsAdapters;

lib/internal/streams/duplexify.js

@@ -29,7 +29,7 @@ const{
 const{ AbortController }=require('internal/abort_controller');
 
 const{
- FunctionPrototypeCall
+ FunctionPrototypeCall,
 }=primordials;
 
 // This is needed for pre node 17.
@@ -90,7 +90,7 @@ module.exports = function duplexify(body, name){
 objectMode: true,
  write,
  final,
- destroy
+ destroy,
 });
 }
 
@@ -126,7 +126,7 @@ module.exports = function duplexify(body, name){
 }
 });
 },
- destroy
+ destroy,
 });
 }
 
@@ -142,7 +142,7 @@ module.exports = function duplexify(body, name){
 returnfrom(Duplexify,body,{
 // TODO (ronag): highWaterMark?
 objectMode: true,
-writable: false
+writable: false,
 });
 }
 
@@ -192,7 +192,7 @@ module.exports = function duplexify(body, name){
 returnd=newDuplexify({
 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;
 
 functionfrom(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{
 conststream=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||newERR_STREAM_DESTROYED('pipe'));
 },
- cleanup
+ cleanup,
 };
 }
 
@@ -314,7 +314,7 @@ function pipelineImpl(streams, callback, opts){
 // composed through `.pipe(stream)`.
 
 constpt=newPassThrough({
-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');
 constdestroyImpl=require('internal/streams/destroy');
 const{
  getHighWaterMark,
- getDefaultHighWaterMark
+ getDefaultHighWaterMark,
 }=require('internal/streams/state');
 
 const{
@@ -65,7 +65,7 @@ const{
 ERR_OUT_OF_RANGE,
 ERR_STREAM_PUSH_AFTER_EOF,
 ERR_STREAM_UNSHIFT_AFTER_END_EVENT,
-}
+},
 }=require('internal/errors');
 const{ validateObject }=require('internal/validators');
 
@@ -1166,15 +1166,15 @@ ObjectDefineProperties(Readable.prototype,{
 if(this._readableState){
 this._readableState.readable=!!val;
 }
-}
+},
 },
 
 readableDidRead: {
 __proto__: null,
 enumerable: false,
 get: function(){
 returnthis._readableState.dataEmitted;
-}
+},
 },
 
 readableAborted: {
@@ -1186,23 +1186,23 @@ ObjectDefineProperties(Readable.prototype,{
 (this._readableState.destroyed||this._readableState.errored)&&
 !this._readableState.endEmitted
 );
-}
+},
 },
 
 readableHighWaterMark: {
 __proto__: null,
 enumerable: false,
 get: function(){
 returnthis._readableState.highWaterMark;
-}
+},
 },
 
 readableBuffer: {
 __proto__: null,
 enumerable: false,
 get: function(){
 returnthis._readableState&&this._readableState.buffer;
-}
+},
 },
 
 readableFlowing: {
@@ -1215,46 +1215,46 @@ ObjectDefineProperties(Readable.prototype,{
 if(this._readableState){
 this._readableState.flowing=state;
 }
-}
+},
 },
 
 readableLength: {
 __proto__: null,
 enumerable: false,
 get(){
 returnthis._readableState.length;
-}
+},
 },
 
 readableObjectMode: {
 __proto__: null,
 enumerable: false,
 get(){
 returnthis._readableState ? this._readableState.objectMode : false;
-}
+},
 },
 
 readableEncoding: {
 __proto__: null,
 enumerable: false,
 get(){
 returnthis._readableState ? this._readableState.encoding : null;
-}
+},
 },
 
 errored: {
 __proto__: null,
 enumerable: false,
 get(){
 returnthis._readableState ? this._readableState.errored : null;
-}
+},
 },
 
 closed: {
 __proto__: null,
 get(){
 returnthis._readableState ? this._readableState.closed : false;
-}
+},
 },
 
 destroyed: {
@@ -1273,15 +1273,15 @@ ObjectDefineProperties(Readable.prototype,{
 // Backward compatibility, the user is explicitly
 // managing destroyed.
 this._readableState.destroyed=value;
-}
+},
 },
 
 readableEnded: {
 __proto__: null,
 enumerable: false,
 get(){
 returnthis._readableState ? this._readableState.endEmitted : false;
-}
+},
 },
 
 });
@@ -1292,7 +1292,7 @@ ObjectDefineProperties(ReadableState.prototype,{
 __proto__: null,
 get(){
 returnthis.pipes.length;
-}
+},
 },
 
 // Legacy property for `paused`.
@@ -1303,8 +1303,8 @@ ObjectDefineProperties(ReadableState.prototype,{
 },
 set(value){
 this[kPaused]=!!value;
-}
-}
+},
+},
 });
 
 // Exposed for testing purposes only.
@@ -1418,6 +1418,6 @@ Readable.wrap = function(src, options){
 destroy(err,callback){
 destroyImpl.destroyer(src,err);
 callback(err);
-}
+},
 }).wrap(src);
 };