Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(649)

Unified Diff: third_party/WebKit/Source/core/streams/ReadableStreamOperations.cpp

Issue 1898873003: Add ReadableStream operations to use it from Fetch API (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@body-stream-buffer-test-refactoring
Patch Set: Created 4 years, 8 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: third_party/WebKit/Source/core/streams/ReadableStreamOperations.cpp
diff --git a/third_party/WebKit/Source/core/streams/ReadableStreamOperations.cpp b/third_party/WebKit/Source/core/streams/ReadableStreamOperations.cpp
index 1410d5d68602e6bbafb093798dd817b52c0e40b4..612a1ad4445b1351a4895226429e19b029497da9 100644
--- a/third_party/WebKit/Source/core/streams/ReadableStreamOperations.cpp
+++ b/third_party/WebKit/Source/core/streams/ReadableStreamOperations.cpp
@@ -65,6 +65,14 @@ bool ReadableStreamOperations::isDisturbed(ScriptState* scriptState, ScriptValue
return V8ScriptRunner::callExtraOrCrash(scriptState, "IsReadableStreamDisturbed", args)->ToBoolean()->Value();
}
+void ReadableStreamOperations::setDisturbed(ScriptState* scriptState, ScriptValue stream)
+{
+ ASSERT(isReadableStream(scriptState, stream));
+
+ v8::Local<v8::Value> args[] = { stream.v8Value() };
+ V8ScriptRunner::callExtraOrCrash(scriptState, "SetReadableStreamDisturbed", args);
+}
+
bool ReadableStreamOperations::isLocked(ScriptState* scriptState, ScriptValue stream)
{
ASSERT(isReadableStream(scriptState, stream));
@@ -73,6 +81,30 @@ bool ReadableStreamOperations::isLocked(ScriptState* scriptState, ScriptValue st
return V8ScriptRunner::callExtraOrCrash(scriptState, "IsReadableStreamLocked", args)->ToBoolean()->Value();
}
+bool ReadableStreamOperations::isReadable(ScriptState* scriptState, ScriptValue stream)
+{
+ ASSERT(isReadableStream(scriptState, stream));
+
+ v8::Local<v8::Value> args[] = { stream.v8Value() };
+ return V8ScriptRunner::callExtraOrCrash(scriptState, "IsReadableStreamReadable", args)->ToBoolean()->Value();
+}
+
+bool ReadableStreamOperations::isClosed(ScriptState* scriptState, ScriptValue stream)
+{
+ ASSERT(isReadableStream(scriptState, stream));
+
+ v8::Local<v8::Value> args[] = { stream.v8Value() };
+ return V8ScriptRunner::callExtraOrCrash(scriptState, "IsReadableStreamClosed", args)->ToBoolean()->Value();
+}
+
+bool ReadableStreamOperations::isErrored(ScriptState* scriptState, ScriptValue stream)
+{
+ ASSERT(isReadableStream(scriptState, stream));
+
+ v8::Local<v8::Value> args[] = { stream.v8Value() };
+ return V8ScriptRunner::callExtraOrCrash(scriptState, "IsReadableStreamErrored", args)->ToBoolean()->Value();
+}
+
bool ReadableStreamOperations::isReadableStreamReader(ScriptState* scriptState, ScriptValue value)
{
ASSERT(!value.isEmpty());

Powered by Google App Engine
This is Rietveld 408576698