aboutsummaryrefslogtreecommitdiff
path: root/src/bun.js/bindings/webcore/ReadableStream.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/bun.js/bindings/webcore/ReadableStream.cpp')
-rw-r--r--src/bun.js/bindings/webcore/ReadableStream.cpp18
1 files changed, 12 insertions, 6 deletions
diff --git a/src/bun.js/bindings/webcore/ReadableStream.cpp b/src/bun.js/bindings/webcore/ReadableStream.cpp
index 0a85942b9..16658638b 100644
--- a/src/bun.js/bindings/webcore/ReadableStream.cpp
+++ b/src/bun.js/bindings/webcore/ReadableStream.cpp
@@ -197,24 +197,30 @@ static inline bool checkReadableStream(JSDOMGlobalObject& globalObject, JSReadab
bool ReadableStream::isLocked() const
{
- return checkReadableStream(*globalObject(), readableStream(), globalObject()->builtinInternalFunctions().readableStreamInternals().m_isReadableStreamLockedFunction.get());
+ auto clientData = WebCore::clientData(m_globalObject->vm());
+ auto& privateName = clientData->builtinNames().readerPrivateName();
+ return readableStream()->getDirect(m_globalObject->vm(), privateName).isTrue();
}
bool ReadableStream::isLocked(JSGlobalObject* globalObject, JSReadableStream* readableStream)
{
- auto* dom = reinterpret_cast<JSDOMGlobalObject*>(globalObject);
- return checkReadableStream(*dom, readableStream, dom->builtinInternalFunctions().readableStreamInternals().m_isReadableStreamLockedFunction.get());
+ auto clientData = WebCore::clientData(globalObject->vm());
+ auto& privateName = clientData->builtinNames().readerPrivateName();
+ return readableStream->getDirect(globalObject->vm(), privateName).isTrue();
}
bool ReadableStream::isDisturbed(JSGlobalObject* globalObject, JSReadableStream* readableStream)
{
- auto* dom = reinterpret_cast<JSDOMGlobalObject*>(globalObject);
- return checkReadableStream(*dom, readableStream, dom->builtinInternalFunctions().readableStreamInternals().m_isReadableStreamDisturbedFunction.get());
+ auto clientData = WebCore::clientData(globalObject->vm());
+ auto& privateName = clientData->builtinNames().disturbedPrivateName();
+ return readableStream->getDirect(globalObject->vm(), privateName).isTrue();
}
bool ReadableStream::isDisturbed() const
{
- return checkReadableStream(*globalObject(), readableStream(), globalObject()->builtinInternalFunctions().readableStreamInternals().m_isReadableStreamDisturbedFunction.get());
+ auto clientData = WebCore::clientData(globalObject()->vm());
+ auto& privateName = clientData->builtinNames().disturbedPrivateName();
+ return readableStream()->getDirect(globalObject()->vm(), privateName).isTrue();
}
}