Skip to content

Commit 3a648af

Browse files
aduh95aduh95
authored
stream: add trailing commas in stream source files
PR-URL: #46686 Reviewed-By: Robert Nagy <ronagy@icloud.com> Reviewed-By: Moshe Atlow <moshe@atlow.co.il> Reviewed-By: Matteo Collina <matteo.collina@gmail.com> Reviewed-By: Darshan Sen <raisinten@gmail.com>
1 parent 109545a commit 3a648af

13 files changed

+64
-63
lines changed

‎lib/.eslintrc.yaml

+1
Original file line numberDiff line numberDiff line change
@@ -290,6 +290,7 @@ overrides:
290290
- ./internal/readme.md
291291
- ./internal/repl/history.js
292292
- ./internal/source_map/prepare_stack_trace.js
293+
- ./internal/streams/*.js
293294
- ./internal/structured_clone.js
294295
- ./internal/test/*.js
295296
- ./internal/test_runner/**/*.js

‎lib/internal/streams/buffer_list.js

+1-1
Original file line numberDiff line numberDiff line change
@@ -175,7 +175,7 @@ module.exports = class BufferList {
175175
// Only inspect one level.
176176
depth: 0,
177177
// It should not recurse.
178-
customInspect: false
178+
customInspect: false,
179179
});
180180
}
181181
};

‎lib/internal/streams/destroy.js

+2-2
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@ const {
1414
kDestroyed,
1515
isDestroyed,
1616
isFinished,
17-
isServerRequest
17+
isServerRequest,
1818
} = require('internal/streams/utils');
1919

2020
const kDestroy = Symbol('kDestroy');
@@ -334,5 +334,5 @@ module.exports = {
334334
destroyer,
335335
destroy,
336336
undestroy,
337-
errorOrDestroy
337+
errorOrDestroy,
338338
};

‎lib/internal/streams/duplex.js

+2-2
Original file line numberDiff line numberDiff line change
@@ -114,8 +114,8 @@ ObjectDefineProperties(Duplex.prototype, {
114114
this._readableState.destroyed = value;
115115
this._writableState.destroyed = value;
116116
}
117-
}
118-
}
117+
},
118+
},
119119
});
120120

121121
let webStreamsAdapters;

‎lib/internal/streams/duplexify.js

+6-6
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@ const {
3232
const { AbortController } = require('internal/abort_controller');
3333

3434
const {
35-
FunctionPrototypeCall
35+
FunctionPrototypeCall,
3636
} = primordials;
3737

3838
// This is needed for pre node 17.
@@ -91,7 +91,7 @@ module.exports = function duplexify(body, name) {
9191
objectMode: true,
9292
write,
9393
final,
94-
destroy
94+
destroy,
9595
});
9696
}
9797

@@ -127,7 +127,7 @@ module.exports = function duplexify(body, name) {
127127
}
128128
});
129129
},
130-
destroy
130+
destroy,
131131
});
132132
}
133133

@@ -143,7 +143,7 @@ module.exports = function duplexify(body, name) {
143143
return from(Duplexify, body, {
144144
// TODO (ronag): highWaterMark?
145145
objectMode: true,
146-
writable: false
146+
writable: false,
147147
});
148148
}
149149

@@ -192,7 +192,7 @@ module.exports = function duplexify(body, name) {
192192
return d = new Duplexify({
193193
objectMode: true,
194194
writable: false,
195-
read() {}
195+
read() {},
196196
});
197197
}
198198

@@ -236,7 +236,7 @@ function fromAsyncGen(fn) {
236236
destroy(err, cb) {
237237
ac.abort();
238238
cb(err);
239-
}
239+
},
240240
};
241241
}
242242

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

+2-2
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,7 @@ const {
99
} = require('internal/errors');
1010
const {
1111
ERR_INVALID_ARG_TYPE,
12-
ERR_STREAM_PREMATURE_CLOSE
12+
ERR_STREAM_PREMATURE_CLOSE,
1313
} = codes;
1414
const {
1515
kEmptyObject,
@@ -19,7 +19,7 @@ const {
1919
validateAbortSignal,
2020
validateFunction,
2121
validateObject,
22-
validateBoolean
22+
validateBoolean,
2323
} = require('internal/validators');
2424

2525
const { Promise, PromisePrototypeThen } = primordials;

‎lib/internal/streams/from.js

+2-2
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,7 @@ const { Buffer } = require('buffer');
99

1010
const {
1111
ERR_INVALID_ARG_TYPE,
12-
ERR_STREAM_NULL_VALUES
12+
ERR_STREAM_NULL_VALUES,
1313
} = require('internal/errors').codes;
1414

1515
function from(Readable, iterable, opts) {
@@ -21,7 +21,7 @@ function from(Readable, iterable, opts) {
2121
read() {
2222
this.push(iterable);
2323
this.push(null);
24-
}
24+
},
2525
});
2626
}
2727

‎lib/internal/streams/lazy_transform.js

+5-5
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,7 @@ const {
1212
const stream = require('stream');
1313

1414
const {
15-
getDefaultEncoding
15+
getDefaultEncoding,
1616
} = require('internal/crypto/util');
1717

1818
module.exports = LazyTransform;
@@ -43,7 +43,7 @@ function makeSetter(name) {
4343
value: val,
4444
enumerable: true,
4545
configurable: true,
46-
writable: true
46+
writable: true,
4747
});
4848
};
4949
}
@@ -54,13 +54,13 @@ ObjectDefineProperties(LazyTransform.prototype, {
5454
get: makeGetter('_readableState'),
5555
set: makeSetter('_readableState'),
5656
configurable: true,
57-
enumerable: true
57+
enumerable: true,
5858
},
5959
_writableState: {
6060
__proto__: null,
6161
get: makeGetter('_writableState'),
6262
set: makeSetter('_writableState'),
6363
configurable: true,
64-
enumerable: true
65-
}
64+
enumerable: true,
65+
},
6666
});

‎lib/internal/streams/pipeline.js

+3-3
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,7 @@ const {
2727

2828
const {
2929
validateFunction,
30-
validateAbortSignal
30+
validateAbortSignal,
3131
} = require('internal/validators');
3232

3333
const {
@@ -60,7 +60,7 @@ function destroyer(stream, reading, writing) {
6060
finished = true;
6161
destroyImpl.destroyer(stream, err || new ERR_STREAM_DESTROYED('pipe'));
6262
},
63-
cleanup
63+
cleanup,
6464
};
6565
}
6666

@@ -314,7 +314,7 @@ function pipelineImpl(streams, callback, opts) {
314314
// composed through `.pipe(stream)`.
315315

316316
const pt = new PassThrough({
317-
objectMode: true
317+
objectMode: true,
318318
});
319319

320320
// Handle Promises/A+ spec, `then` could be a getter that throws on

‎lib/internal/streams/readable.js

+21-21
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@ const {
3232
Promise,
3333
SafeSet,
3434
SymbolAsyncIterator,
35-
Symbol
35+
Symbol,
3636
} = primordials;
3737

3838
module.exports = Readable;
@@ -54,7 +54,7 @@ const BufferList = require('internal/streams/buffer_list');
5454
const destroyImpl = require('internal/streams/destroy');
5555
const {
5656
getHighWaterMark,
57-
getDefaultHighWaterMark
57+
getDefaultHighWaterMark,
5858
} = require('internal/streams/state');
5959

6060
const {
@@ -65,8 +65,8 @@ const {
6565
ERR_OUT_OF_RANGE,
6666
ERR_STREAM_PUSH_AFTER_EOF,
6767
ERR_STREAM_UNSHIFT_AFTER_END_EVENT,
68-
ERR_UNKNOWN_ENCODING
69-
}
68+
ERR_UNKNOWN_ENCODING,
69+
},
7070
} = require('internal/errors');
7171
const { validateObject } = require('internal/validators');
7272

@@ -1174,15 +1174,15 @@ ObjectDefineProperties(Readable.prototype, {
11741174
if (this._readableState) {
11751175
this._readableState.readable = !!val;
11761176
}
1177-
}
1177+
},
11781178
},
11791179

11801180
readableDidRead: {
11811181
__proto__: null,
11821182
enumerable: false,
11831183
get: function() {
11841184
return this._readableState.dataEmitted;
1185-
}
1185+
},
11861186
},
11871187

11881188
readableAborted: {
@@ -1194,23 +1194,23 @@ ObjectDefineProperties(Readable.prototype, {
11941194
(this._readableState.destroyed || this._readableState.errored) &&
11951195
!this._readableState.endEmitted
11961196
);
1197-
}
1197+
},
11981198
},
11991199

12001200
readableHighWaterMark: {
12011201
__proto__: null,
12021202
enumerable: false,
12031203
get: function() {
12041204
return this._readableState.highWaterMark;
1205-
}
1205+
},
12061206
},
12071207

12081208
readableBuffer: {
12091209
__proto__: null,
12101210
enumerable: false,
12111211
get: function() {
12121212
return this._readableState && this._readableState.buffer;
1213-
}
1213+
},
12141214
},
12151215

12161216
readableFlowing: {
@@ -1223,46 +1223,46 @@ ObjectDefineProperties(Readable.prototype, {
12231223
if (this._readableState) {
12241224
this._readableState.flowing = state;
12251225
}
1226-
}
1226+
},
12271227
},
12281228

12291229
readableLength: {
12301230
__proto__: null,
12311231
enumerable: false,
12321232
get() {
12331233
return this._readableState.length;
1234-
}
1234+
},
12351235
},
12361236

12371237
readableObjectMode: {
12381238
__proto__: null,
12391239
enumerable: false,
12401240
get() {
12411241
return this._readableState ? this._readableState.objectMode : false;
1242-
}
1242+
},
12431243
},
12441244

12451245
readableEncoding: {
12461246
__proto__: null,
12471247
enumerable: false,
12481248
get() {
12491249
return this._readableState ? this._readableState.encoding : null;
1250-
}
1250+
},
12511251
},
12521252

12531253
errored: {
12541254
__proto__: null,
12551255
enumerable: false,
12561256
get() {
12571257
return this._readableState ? this._readableState.errored : null;
1258-
}
1258+
},
12591259
},
12601260

12611261
closed: {
12621262
__proto__: null,
12631263
get() {
12641264
return this._readableState ? this._readableState.closed : false;
1265-
}
1265+
},
12661266
},
12671267

12681268
destroyed: {
@@ -1281,15 +1281,15 @@ ObjectDefineProperties(Readable.prototype, {
12811281
// Backward compatibility, the user is explicitly
12821282
// managing destroyed.
12831283
this._readableState.destroyed = value;
1284-
}
1284+
},
12851285
},
12861286

12871287
readableEnded: {
12881288
__proto__: null,
12891289
enumerable: false,
12901290
get() {
12911291
return this._readableState ? this._readableState.endEmitted : false;
1292-
}
1292+
},
12931293
},
12941294

12951295
});
@@ -1300,7 +1300,7 @@ ObjectDefineProperties(ReadableState.prototype, {
13001300
__proto__: null,
13011301
get() {
13021302
return this.pipes.length;
1303-
}
1303+
},
13041304
},
13051305

13061306
// Legacy property for `paused`.
@@ -1311,8 +1311,8 @@ ObjectDefineProperties(ReadableState.prototype, {
13111311
},
13121312
set(value) {
13131313
this[kPaused] = !!value;
1314-
}
1315-
}
1314+
},
1315+
},
13161316
});
13171317

13181318
// Exposed for testing purposes only.
@@ -1426,6 +1426,6 @@ Readable.wrap = function(src, options) {
14261426
destroy(err, callback) {
14271427
destroyImpl.destroyer(src, err);
14281428
callback(err);
1429-
}
1429+
},
14301430
}).wrap(src);
14311431
};

‎lib/internal/streams/state.js

+1-1
Original file line numberDiff line numberDiff line change
@@ -32,5 +32,5 @@ function getHighWaterMark(state, options, duplexKey, isDuplex) {
3232

3333
module.exports = {
3434
getHighWaterMark,
35-
getDefaultHighWaterMark
35+
getDefaultHighWaterMark,
3636
};

‎lib/internal/streams/transform.js

+2-2
Original file line numberDiff line numberDiff line change
@@ -70,7 +70,7 @@ const {
7070

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

0 commit comments

Comments
 (0)