| 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
|
|
|