Add ReadableStream operations to use it from Fetch API

third_party/WebKit/Source/core/streams/ReadableStreamOperations.cpp

 // Copyright 2015 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "core/streams/ReadableStreamOperations.h"
 
 #include "bindings/core/v8/ExceptionState.h"
 #include "bindings/core/v8/ScriptState.h"
 #include "bindings/core/v8/ToV8.h"
 #include "bindings/core/v8/V8ScriptRunner.h"
@@ skipping 47 matching lines @@
 }
 
 bool ReadableStreamOperations::isDisturbed(ScriptState* scriptState, ScriptValue stream)
 {
     ASSERT(isReadableStream(scriptState, stream));
 
     v8::Local<v8::Value> args[] = { stream.v8Value() };
     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));
 
     v8::Local<v8::Value> args[] = { stream.v8Value() };
     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());
 
     if (!value.isObject())
         return false;
 
     v8::Local<v8::Value> args[] = { value.v8Value() };
     return V8ScriptRunner::callExtraOrCrash(scriptState, "IsReadableStreamReader", args)->ToBoolean()->Value();
 }
 
 ScriptPromise ReadableStreamOperations::read(ScriptState* scriptState, ScriptValue reader)
 {
     ASSERT(isReadableStreamReader(scriptState, reader));
 
     v8::Local<v8::Value> args[] = { reader.v8Value() };
     return ScriptPromise::cast(scriptState, V8ScriptRunner::callExtraOrCrash(scriptState, "ReadFromReadableStreamReader", args));
 }
 
 } // namespace blink