summaryrefslogtreecommitdiff
path: root/ext/web/06_streams.js
diff options
context:
space:
mode:
Diffstat (limited to 'ext/web/06_streams.js')
-rw-r--r--ext/web/06_streams.js28
1 files changed, 19 insertions, 9 deletions
diff --git a/ext/web/06_streams.js b/ext/web/06_streams.js
index 7ef5a6131..6daea0898 100644
--- a/ext/web/06_streams.js
+++ b/ext/web/06_streams.js
@@ -41,6 +41,7 @@
PromiseResolve,
queueMicrotask,
RangeError,
+ ReflectHas,
SharedArrayBuffer,
Symbol,
SymbolAsyncIterator,
@@ -190,7 +191,7 @@
* @returns {boolean}
*/
function isDetachedBuffer(O) {
- return isFakeDetached in O;
+ return ReflectHas(O, isFakeDetached);
}
/**
@@ -392,7 +393,10 @@
* @returns {T}
*/
function dequeueValue(container) {
- assert(_queue in container && _queueTotalSize in container);
+ assert(
+ ReflectHas(container, _queue) &&
+ ReflectHas(container, _queueTotalSize),
+ );
assert(container[_queue].length);
const valueWithSize = ArrayPrototypeShift(container[_queue]);
container[_queueTotalSize] -= valueWithSize.size;
@@ -410,7 +414,10 @@
* @returns {void}
*/
function enqueueValueWithSize(container, value, size) {
- assert(_queue in container && _queueTotalSize in container);
+ assert(
+ ReflectHas(container, _queue) &&
+ ReflectHas(container, _queueTotalSize),
+ );
if (isNonNegativeNumber(size) === false) {
throw RangeError("chunk size isn't a positive number");
}
@@ -592,7 +599,7 @@
*/
function isReadableStream(value) {
return !(typeof value !== "object" || value === null ||
- !(_controller in value));
+ !ReflectHas(value, _controller));
}
/**
@@ -612,7 +619,7 @@
*/
function isReadableStreamDefaultReader(value) {
return !(typeof value !== "object" || value === null ||
- !(_readRequests in value));
+ !ReflectHas(value, _readRequests));
}
/**
@@ -621,7 +628,7 @@
*/
function isReadableStreamBYOBReader(value) {
return !(typeof value !== "object" || value === null ||
- !(_readIntoRequests in value));
+ !ReflectHas(value, _readIntoRequests));
}
/**
@@ -639,7 +646,7 @@
*/
function isWritableStream(value) {
return !(typeof value !== "object" || value === null ||
- !(_controller in value));
+ !ReflectHas(value, _controller));
}
/**
@@ -659,7 +666,10 @@
* @returns {T | _close}
*/
function peekQueueValue(container) {
- assert(_queue in container && _queueTotalSize in container);
+ assert(
+ ReflectHas(container, _queue) &&
+ ReflectHas(container, _queueTotalSize),
+ );
assert(container[_queue].length);
const valueWithSize = container[_queue][0];
return valueWithSize.value;
@@ -4333,7 +4343,7 @@
highWaterMark,
);
} else {
- assert(!("type" in underlyingSourceDict));
+ assert(!(ReflectHas(underlyingSourceDict, "type")));
const sizeAlgorithm = extractSizeAlgorithm(strategy);
const highWaterMark = extractHighWaterMark(strategy, 1);
setUpReadableStreamDefaultControllerFromUnderlyingSource(