stream: add trailing commas in webstream source files
PR-URL: https://github.com/nodejs/node/pull/46685 Reviewed-By: Moshe Atlow <moshe@atlow.co.il> Reviewed-By: Darshan Sen <raisinten@gmail.com>
This commit is contained in:
parent
3a648af0f0
commit
d42628d05a
@ -300,6 +300,7 @@ overrides:
|
|||||||
- ./internal/vm.js
|
- ./internal/vm.js
|
||||||
- ./internal/watch_mode/*.js
|
- ./internal/watch_mode/*.js
|
||||||
- ./internal/webidl.js
|
- ./internal/webidl.js
|
||||||
|
- ./internal/webstreams/*.js
|
||||||
- ./module.js
|
- ./module.js
|
||||||
- ./path/*.js
|
- ./path/*.js
|
||||||
- ./process.js
|
- ./process.js
|
||||||
|
@ -504,7 +504,7 @@ class ReadableStream {
|
|||||||
done = true;
|
done = true;
|
||||||
readableStreamReaderGenericRelease(reader);
|
readableStreamReaderGenericRelease(reader);
|
||||||
promise.reject(error);
|
promise.reject(error);
|
||||||
}
|
},
|
||||||
});
|
});
|
||||||
return promise.promise;
|
return promise.promise;
|
||||||
}
|
}
|
||||||
@ -567,7 +567,7 @@ class ReadableStream {
|
|||||||
returnSteps(error);
|
returnSteps(error);
|
||||||
},
|
},
|
||||||
|
|
||||||
[SymbolAsyncIterator]() { return this; }
|
[SymbolAsyncIterator]() { return this; },
|
||||||
}, AsyncIterator);
|
}, AsyncIterator);
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -605,7 +605,7 @@ class ReadableStream {
|
|||||||
return {
|
return {
|
||||||
data: { port: this[kState].transfer.port2 },
|
data: { port: this[kState].transfer.port2 },
|
||||||
deserializeInfo:
|
deserializeInfo:
|
||||||
'internal/webstreams/readablestream:TransferredReadableStream'
|
'internal/webstreams/readablestream:TransferredReadableStream',
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -1225,7 +1225,7 @@ function createTeeReadableStream(start, pull, cancel) {
|
|||||||
ObjectCreate(null, {
|
ObjectCreate(null, {
|
||||||
start: { __proto__: null, value: start },
|
start: { __proto__: null, value: start },
|
||||||
pull: { __proto__: null, value: pull },
|
pull: { __proto__: null, value: pull },
|
||||||
cancel: { __proto__: null, value: cancel }
|
cancel: { __proto__: null, value: cancel },
|
||||||
}),
|
}),
|
||||||
1,
|
1,
|
||||||
() => 1);
|
() => 1);
|
||||||
@ -1917,7 +1917,7 @@ function readableStreamError(stream, error) {
|
|||||||
setPromiseHandled(stream[kIsClosedPromise].promise);
|
setPromiseHandled(stream[kIsClosedPromise].promise);
|
||||||
|
|
||||||
const {
|
const {
|
||||||
reader
|
reader,
|
||||||
} = stream[kState];
|
} = stream[kState];
|
||||||
|
|
||||||
if (reader === undefined)
|
if (reader === undefined)
|
||||||
|
@ -66,7 +66,7 @@ class CloneableDOMException extends DOMException {
|
|||||||
code: this.code,
|
code: this.code,
|
||||||
},
|
},
|
||||||
deserializeInfo:
|
deserializeInfo:
|
||||||
'internal/webstreams/transfer:InternalCloneableDOMException'
|
'internal/webstreams/transfer:InternalCloneableDOMException',
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -183,7 +183,7 @@ class CrossRealmTransformWritableSink {
|
|||||||
assert(typeof data === 'object');
|
assert(typeof data === 'object');
|
||||||
const {
|
const {
|
||||||
type,
|
type,
|
||||||
value
|
value,
|
||||||
} = { ...data };
|
} = { ...data };
|
||||||
assert(typeof type === 'string');
|
assert(typeof type === 'string');
|
||||||
switch (type) {
|
switch (type) {
|
||||||
|
@ -226,7 +226,7 @@ class TransformStream {
|
|||||||
writable,
|
writable,
|
||||||
},
|
},
|
||||||
deserializeInfo:
|
deserializeInfo:
|
||||||
'internal/webstreams/transformstream:TransferredTransformStream'
|
'internal/webstreams/transformstream:TransferredTransformStream',
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -398,7 +398,7 @@ function initializeTransformStream(
|
|||||||
promise: undefined,
|
promise: undefined,
|
||||||
resolve: undefined,
|
resolve: undefined,
|
||||||
reject: undefined,
|
reject: undefined,
|
||||||
}
|
},
|
||||||
};
|
};
|
||||||
|
|
||||||
transformStreamSetBackpressure(stream, true);
|
transformStreamSetBackpressure(stream, true);
|
||||||
|
@ -25,7 +25,7 @@ const {
|
|||||||
|
|
||||||
const {
|
const {
|
||||||
copyArrayBuffer,
|
copyArrayBuffer,
|
||||||
detachArrayBuffer
|
detachArrayBuffer,
|
||||||
} = internalBinding('buffer');
|
} = internalBinding('buffer');
|
||||||
|
|
||||||
const {
|
const {
|
||||||
@ -81,7 +81,7 @@ function customInspect(depth, options, name, data) {
|
|||||||
|
|
||||||
const opts = {
|
const opts = {
|
||||||
...options,
|
...options,
|
||||||
depth: options.depth == null ? null : options.depth - 1
|
depth: options.depth == null ? null : options.depth - 1,
|
||||||
};
|
};
|
||||||
|
|
||||||
return `${name} ${inspect(data, opts)}`;
|
return `${name} ${inspect(data, opts)}`;
|
||||||
|
@ -299,7 +299,7 @@ class WritableStream {
|
|||||||
return {
|
return {
|
||||||
data: { port: this[kState].transfer.port2 },
|
data: { port: this[kState].transfer.port2 },
|
||||||
deserializeInfo:
|
deserializeInfo:
|
||||||
'internal/webstreams/writablestream:TransferredWritableStream'
|
'internal/webstreams/writablestream:TransferredWritableStream',
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -398,7 +398,7 @@ class WritableStreamDefaultWriter {
|
|||||||
promise: undefined,
|
promise: undefined,
|
||||||
resolve: undefined,
|
resolve: undefined,
|
||||||
reject: undefined,
|
reject: undefined,
|
||||||
}
|
},
|
||||||
};
|
};
|
||||||
setupWritableStreamDefaultWriter(this, stream);
|
setupWritableStreamDefaultWriter(this, stream);
|
||||||
}
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user