Index: third_party/WebKit/Source/modules/fetch/BytesConsumerTest.cpp |
diff --git a/third_party/WebKit/Source/modules/fetch/BytesConsumerTest.cpp b/third_party/WebKit/Source/modules/fetch/BytesConsumerTest.cpp |
index 47ad1ac5a730d3a4b2a34d0f8f557a509376a331..d05d7beed6e48534f913215651e4779d5fc7ed07 100644 |
--- a/third_party/WebKit/Source/modules/fetch/BytesConsumerTest.cpp |
+++ b/third_party/WebKit/Source/modules/fetch/BytesConsumerTest.cpp |
@@ -408,6 +408,29 @@ TEST_F(BytesConsumerTeeTest, |
EXPECT_EQ(BytesConsumer::PublicState::Closed, dest1->getPublicState()); |
} |
+TEST(BytesConusmerTest, ClosedBytesConsumer) { |
+ BytesConsumer* consumer = BytesConsumer::createClosed(); |
+ |
+ const char* buffer = nullptr; |
+ size_t available = 0; |
+ EXPECT_EQ(Result::Done, consumer->beginRead(&buffer, &available)); |
+ EXPECT_EQ(BytesConsumer::PublicState::Closed, consumer->getPublicState()); |
+} |
+ |
+TEST(BytesConusmerTest, ErroredBytesConsumer) { |
+ BytesConsumer::Error error("hello"); |
+ BytesConsumer* consumer = BytesConsumer::createErrored(error); |
+ |
+ const char* buffer = nullptr; |
+ size_t available = 0; |
+ EXPECT_EQ(Result::Error, consumer->beginRead(&buffer, &available)); |
+ EXPECT_EQ(BytesConsumer::PublicState::Errored, consumer->getPublicState()); |
+ EXPECT_EQ(error.message(), consumer->getError().message()); |
+ |
+ consumer->cancel(); |
+ EXPECT_EQ(BytesConsumer::PublicState::Errored, consumer->getPublicState()); |
+} |
+ |
} // namespace |
} // namespace blink |