Add ReadableStream operations to use it from Fetch API

third_party/WebKit/Source/core/streams/ReadableStreamOperationsTest.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/ScriptFunction.h"
 #include "bindings/core/v8/ScriptState.h"
 #include "bindings/core/v8/ScriptValue.h"
@@ skipping 316 matching lines @@
     EXPECT_FALSE(it3->isSet());
 
     underlyingSource->close();
     v8::MicrotasksScope::PerformCheckpoint(isolate());
 
     EXPECT_TRUE(it3->isSet());
     EXPECT_TRUE(it3->isValid());
     EXPECT_TRUE(it3->isDone());
 }
 
+TEST_F(ReadableStreamOperationsTest, SetDisturbed)
+{
+    ScriptValue stream = evalWithPrintingError("new ReadableStream()");
+    ASSERT_FALSE(stream.isEmpty());
+
+    EXPECT_FALSE(ReadableStreamOperations::isDisturbed(getScriptState(), stream));
+    ReadableStreamOperations::setDisturbed(getScriptState(), stream);
+    EXPECT_TRUE(ReadableStreamOperations::isDisturbed(getScriptState(), stream));
+}
+
+TEST_F(ReadableStreamOperationsTest, IsReadable)
+{
+    ScriptValue readable = evalWithPrintingError("new ReadableStream()");
+    ScriptValue closed = evalWithPrintingError("new ReadableStream({start: c => c.close()})");
+    ScriptValue errored = evalWithPrintingError("new ReadableStream({start: c => c.error()})");
+    ASSERT_FALSE(readable.isEmpty());
+    ASSERT_FALSE(closed.isEmpty());
+    ASSERT_FALSE(errored.isEmpty());
+
+    EXPECT_TRUE(ReadableStreamOperations::isReadable(getScriptState(), readable));
+    EXPECT_FALSE(ReadableStreamOperations::isReadable(getScriptState(), closed));
+    EXPECT_FALSE(ReadableStreamOperations::isReadable(getScriptState(), errored));
+}
+
+TEST_F(ReadableStreamOperationsTest, IsClosed)
+{
+    ScriptValue readable = evalWithPrintingError("new ReadableStream()");
+    ScriptValue closed = evalWithPrintingError("new ReadableStream({start: c => c.close()})");
+    ScriptValue errored = evalWithPrintingError("new ReadableStream({start: c => c.error()})");
+    ASSERT_FALSE(readable.isEmpty());
+    ASSERT_FALSE(closed.isEmpty());
+    ASSERT_FALSE(errored.isEmpty());
+
+    EXPECT_FALSE(ReadableStreamOperations::isClosed(getScriptState(), readable));
+    EXPECT_TRUE(ReadableStreamOperations::isClosed(getScriptState(), closed));
+    EXPECT_FALSE(ReadableStreamOperations::isClosed(getScriptState(), errored));
+}
+
+TEST_F(ReadableStreamOperationsTest, IsErrored)
+{
+    ScriptValue readable = evalWithPrintingError("new ReadableStream()");
+    ScriptValue closed = evalWithPrintingError("new ReadableStream({start: c => c.close()})");
+    ScriptValue errored = evalWithPrintingError("new ReadableStream({start: c => c.error()})");
+    ASSERT_FALSE(readable.isEmpty());
+    ASSERT_FALSE(closed.isEmpty());
+    ASSERT_FALSE(errored.isEmpty());
+
+    EXPECT_FALSE(ReadableStreamOperations::isErrored(getScriptState(), readable));
+    EXPECT_FALSE(ReadableStreamOperations::isErrored(getScriptState(), closed));
+    EXPECT_TRUE(ReadableStreamOperations::isErrored(getScriptState(), errored));
+}
+
 } // namespace
 
 } // namespace blink