Add ReadableStream operations to use it from Fetch API

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

Index: third_party/WebKit/Source/core/streams/ReadableStreamOperationsTest.cpp
diff --git a/third_party/WebKit/Source/core/streams/ReadableStreamOperationsTest.cpp b/third_party/WebKit/Source/core/streams/ReadableStreamOperationsTest.cpp
index 7bfa71df64d62acaf467de2723f2648aba5d8c70..d3b9175e5b7b3c770c1dcb2d33952ec65c2c931c 100644
--- a/third_party/WebKit/Source/core/streams/ReadableStreamOperationsTest.cpp
+++ b/third_party/WebKit/Source/core/streams/ReadableStreamOperationsTest.cpp
@@ -334,6 +334,58 @@ TEST_F(ReadableStreamOperationsTest, CreateReadableStreamWithCustomUnderlyingSou
     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