| 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());
|
|
|