Skip to content

Commit

Permalink
stream: add trailing commas in webstream source files
Browse files Browse the repository at this point in the history
PR-URL: #46685
Reviewed-By: Moshe Atlow <[email protected]>
Reviewed-By: Darshan Sen <[email protected]>
  • Loading branch information
aduh95 authored and MylesBorins committed Feb 20, 2023
1 parent 6b64a94 commit 7756438
Show file tree
Hide file tree
Showing 6 changed files with 14 additions and 13 deletions.
1 change: 1 addition & 0 deletions lib/.eslintrc.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -300,6 +300,7 @@ overrides:
- ./internal/vm.js
- ./internal/watch_mode/*.js
- ./internal/webidl.js
- ./internal/webstreams/*.js
- ./module.js
- ./path/*.js
- ./process.js
Expand Down
10 changes: 5 additions & 5 deletions lib/internal/webstreams/readablestream.js
Original file line number Diff line number Diff line change
Expand Up @@ -504,7 +504,7 @@ class ReadableStream {
done = true;
readableStreamReaderGenericRelease(reader);
promise.reject(error);
}
},
});
return promise.promise;
}
Expand Down Expand Up @@ -567,7 +567,7 @@ class ReadableStream {
returnSteps(error);
},

[SymbolAsyncIterator]() { return this; }
[SymbolAsyncIterator]() { return this; },
}, AsyncIterator);
}

Expand Down Expand Up @@ -605,7 +605,7 @@ class ReadableStream {
return {
data: { port: this[kState].transfer.port2 },
deserializeInfo:
'internal/webstreams/readablestream:TransferredReadableStream'
'internal/webstreams/readablestream:TransferredReadableStream',
};
}

Expand Down Expand Up @@ -1225,7 +1225,7 @@ function createTeeReadableStream(start, pull, cancel) {
ObjectCreate(null, {
start: { __proto__: null, value: start },
pull: { __proto__: null, value: pull },
cancel: { __proto__: null, value: cancel }
cancel: { __proto__: null, value: cancel },
}),
1,
() => 1);
Expand Down Expand Up @@ -1917,7 +1917,7 @@ function readableStreamError(stream, error) {
setPromiseHandled(stream[kIsClosedPromise].promise);

const {
reader
reader,
} = stream[kState];

if (reader === undefined)
Expand Down
4 changes: 2 additions & 2 deletions lib/internal/webstreams/transfer.js
Original file line number Diff line number Diff line change
Expand Up @@ -66,7 +66,7 @@ class CloneableDOMException extends DOMException {
code: this.code,
},
deserializeInfo:
'internal/webstreams/transfer:InternalCloneableDOMException'
'internal/webstreams/transfer:InternalCloneableDOMException',
};
}

Expand Down Expand Up @@ -183,7 +183,7 @@ class CrossRealmTransformWritableSink {
assert(typeof data === 'object');
const {
type,
value
value,
} = { ...data };
assert(typeof type === 'string');
switch (type) {
Expand Down
4 changes: 2 additions & 2 deletions lib/internal/webstreams/transformstream.js
Original file line number Diff line number Diff line change
Expand Up @@ -226,7 +226,7 @@ class TransformStream {
writable,
},
deserializeInfo:
'internal/webstreams/transformstream:TransferredTransformStream'
'internal/webstreams/transformstream:TransferredTransformStream',
};
}

Expand Down Expand Up @@ -398,7 +398,7 @@ function initializeTransformStream(
promise: undefined,
resolve: undefined,
reject: undefined,
}
},
};

transformStreamSetBackpressure(stream, true);
Expand Down
4 changes: 2 additions & 2 deletions lib/internal/webstreams/util.js
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@ const {

const {
copyArrayBuffer,
detachArrayBuffer
detachArrayBuffer,
} = internalBinding('buffer');

const {
Expand Down Expand Up @@ -81,7 +81,7 @@ function customInspect(depth, options, name, data) {

const opts = {
...options,
depth: options.depth == null ? null : options.depth - 1
depth: options.depth == null ? null : options.depth - 1,
};

return `${name} ${inspect(data, opts)}`;
Expand Down
4 changes: 2 additions & 2 deletions lib/internal/webstreams/writablestream.js
Original file line number Diff line number Diff line change
Expand Up @@ -299,7 +299,7 @@ class WritableStream {
return {
data: { port: this[kState].transfer.port2 },
deserializeInfo:
'internal/webstreams/writablestream:TransferredWritableStream'
'internal/webstreams/writablestream:TransferredWritableStream',
};
}

Expand Down Expand Up @@ -398,7 +398,7 @@ class WritableStreamDefaultWriter {
promise: undefined,
resolve: undefined,
reject: undefined,
}
},
};
setupWritableStreamDefaultWriter(this, stream);
}
Expand Down

0 comments on commit 7756438

Please sign in to comment.