Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(886)

Issues Search
    My Issues | Starred     Open | Closed | All

Unified Diff: third_party/WebKit/Source/modules/fetch/ReadableStreamDataConsumerHandleTest.cpp

Issue 2365853002: Implement ReadableStreamBytesConsumer (Closed)
Patch Set: git cl format Created 4 years, 2 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « third_party/WebKit/Source/modules/fetch/ReadableStreamDataConsumerHandle.cpp ('k') | third_party/WebKit/Source/modules/fetch/Response.cpp » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: third_party/WebKit/Source/modules/fetch/ReadableStreamDataConsumerHandleTest.cpp
diff --git a/third_party/WebKit/Source/modules/fetch/ReadableStreamDataConsumerHandleTest.cpp b/third_party/WebKit/Source/modules/fetch/ReadableStreamDataConsumerHandleTest.cpp
deleted file mode 100644
index f22594657b933579c7cba42ee34c2413440326ba..0000000000000000000000000000000000000000
--- a/third_party/WebKit/Source/modules/fetch/ReadableStreamDataConsumerHandleTest.cpp
+++ /dev/null
@@ -1,555 +0,0 @@
-// 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 "modules/fetch/ReadableStreamDataConsumerHandle.h"
-
-#include "bindings/core/v8/ScriptState.h"
-#include "bindings/core/v8/V8BindingMacros.h"
-#include "bindings/core/v8/V8GCController.h"
-#include "core/dom/Document.h"
-#include "core/streams/ReadableStreamOperations.h"
-#include "core/testing/DummyPageHolder.h"
-#include "modules/fetch/DataConsumerHandleTestUtil.h"
-#include "platform/heap/Handle.h"
-#include "platform/testing/UnitTestHelpers.h"
-#include "public/platform/WebDataConsumerHandle.h"
-#include "testing/gmock/include/gmock/gmock.h"
-#include "testing/gtest/include/gtest/gtest.h"
-#include <memory>
-#include <v8.h>
-
-// TODO(yhirano): Add cross-thread tests once the handle gets thread-safe.
-namespace blink {
-
-namespace {
-
-using ::testing::InSequence;
-using ::testing::StrictMock;
-using Checkpoint = StrictMock<::testing::MockFunction<void(int)>>;
-using Result = WebDataConsumerHandle::Result;
-const Result kOk = WebDataConsumerHandle::Ok;
-const Result kShouldWait = WebDataConsumerHandle::ShouldWait;
-const Result kUnexpectedError = WebDataConsumerHandle::UnexpectedError;
-const Result kDone = WebDataConsumerHandle::Done;
-using Flags = WebDataConsumerHandle::Flags;
-const Flags kNone = WebDataConsumerHandle::FlagNone;
-
-class MockClient : public GarbageCollectedFinalized<MockClient>,
- public WebDataConsumerHandle::Client {
- public:
- static StrictMock<MockClient>* create() {
- return new StrictMock<MockClient>();
- }
- MOCK_METHOD0(didGetReadable, void());
-
- DEFINE_INLINE_TRACE() {}
-
- protected:
- MockClient() = default;
-};
-
-class ReadableStreamDataConsumerHandleTest : public ::testing::Test {
- public:
- ReadableStreamDataConsumerHandleTest() : m_page(DummyPageHolder::create()) {}
-
- ScriptState* getScriptState() {
- return ScriptState::forMainWorld(m_page->document().frame());
- }
- v8::Isolate* isolate() { return getScriptState()->isolate(); }
-
- v8::MaybeLocal<v8::Value> eval(const char* s) {
- v8::Local<v8::String> source;
- v8::Local<v8::Script> script;
- v8::MicrotasksScope microtasks(isolate(),
- v8::MicrotasksScope::kDoNotRunMicrotasks);
- if (!v8Call(
- v8::String::NewFromUtf8(isolate(), s, v8::NewStringType::kNormal),
- source)) {
- ADD_FAILURE();
- return v8::MaybeLocal<v8::Value>();
- }
- if (!v8Call(v8::Script::Compile(getScriptState()->context(), source),
- script)) {
- ADD_FAILURE() << "Compilation fails";
- return v8::MaybeLocal<v8::Value>();
- }
- return script->Run(getScriptState()->context());
- }
- v8::MaybeLocal<v8::Value> evalWithPrintingError(const char* s) {
- v8::TryCatch block(isolate());
- v8::MaybeLocal<v8::Value> r = eval(s);
- if (block.HasCaught()) {
- ADD_FAILURE()
- << toCoreString(block.Exception()->ToString(isolate())).utf8().data();
- block.ReThrow();
- }
- return r;
- }
-
- std::unique_ptr<ReadableStreamDataConsumerHandle> createHandle(
- ScriptValue stream) {
- NonThrowableExceptionState es;
- ScriptValue reader =
- ReadableStreamOperations::getReader(getScriptState(), stream, es);
- ASSERT(!reader.isEmpty());
- ASSERT(reader.v8Value()->IsObject());
- return ReadableStreamDataConsumerHandle::create(getScriptState(), reader);
- }
-
- void gc() { V8GCController::collectAllGarbageForTesting(isolate()); }
-
- private:
- std::unique_ptr<DummyPageHolder> m_page;
-};
-
-TEST_F(ReadableStreamDataConsumerHandleTest, Create) {
- ScriptState::Scope scope(getScriptState());
- ScriptValue stream(getScriptState(),
- evalWithPrintingError("new ReadableStream"));
- ASSERT_FALSE(stream.isEmpty());
- std::unique_ptr<ReadableStreamDataConsumerHandle> handle =
- createHandle(stream);
- ASSERT_TRUE(handle);
- Persistent<MockClient> client = MockClient::create();
- Checkpoint checkpoint;
-
- InSequence s;
- EXPECT_CALL(checkpoint, Call(1));
- EXPECT_CALL(*client, didGetReadable());
- EXPECT_CALL(checkpoint, Call(2));
-
- std::unique_ptr<FetchDataConsumerHandle::Reader> reader =
- handle->obtainFetchDataReader(client);
- ASSERT_TRUE(reader);
- checkpoint.Call(1);
- testing::runPendingTasks();
- checkpoint.Call(2);
-}
-
-TEST_F(ReadableStreamDataConsumerHandleTest, EmptyStream) {
- ScriptState::Scope scope(getScriptState());
- ScriptValue stream(
- getScriptState(),
- evalWithPrintingError("new ReadableStream({start: c => c.close()})"));
- ASSERT_FALSE(stream.isEmpty());
- std::unique_ptr<ReadableStreamDataConsumerHandle> handle =
- createHandle(stream);
- ASSERT_TRUE(handle);
- Persistent<MockClient> client = MockClient::create();
- Checkpoint checkpoint;
-
- InSequence s;
- EXPECT_CALL(checkpoint, Call(1));
- EXPECT_CALL(*client, didGetReadable());
- EXPECT_CALL(checkpoint, Call(2));
- EXPECT_CALL(*client, didGetReadable());
- EXPECT_CALL(checkpoint, Call(3));
-
- char c;
- size_t readBytes;
- std::unique_ptr<FetchDataConsumerHandle::Reader> reader =
- handle->obtainFetchDataReader(client);
- ASSERT_TRUE(reader);
- checkpoint.Call(1);
- testing::runPendingTasks();
- checkpoint.Call(2);
- EXPECT_EQ(kShouldWait, reader->read(&c, 1, kNone, &readBytes));
- testing::runPendingTasks();
- checkpoint.Call(3);
- EXPECT_EQ(kDone, reader->read(&c, 1, kNone, &readBytes));
-}
-
-TEST_F(ReadableStreamDataConsumerHandleTest, ErroredStream) {
- ScriptState::Scope scope(getScriptState());
- ScriptValue stream(
- getScriptState(),
- evalWithPrintingError("new ReadableStream({start: c => c.error()})"));
- ASSERT_FALSE(stream.isEmpty());
- std::unique_ptr<ReadableStreamDataConsumerHandle> handle =
- createHandle(stream);
- ASSERT_TRUE(handle);
- Persistent<MockClient> client = MockClient::create();
- Checkpoint checkpoint;
-
- InSequence s;
- EXPECT_CALL(checkpoint, Call(1));
- EXPECT_CALL(*client, didGetReadable());
- EXPECT_CALL(checkpoint, Call(2));
- EXPECT_CALL(*client, didGetReadable());
- EXPECT_CALL(checkpoint, Call(3));
-
- char c;
- size_t readBytes;
- std::unique_ptr<FetchDataConsumerHandle::Reader> reader =
- handle->obtainFetchDataReader(client);
- ASSERT_TRUE(reader);
- checkpoint.Call(1);
- testing::runPendingTasks();
- checkpoint.Call(2);
- EXPECT_EQ(kShouldWait, reader->read(&c, 1, kNone, &readBytes));
- testing::runPendingTasks();
- checkpoint.Call(3);
- EXPECT_EQ(kUnexpectedError, reader->read(&c, 1, kNone, &readBytes));
-}
-
-TEST_F(ReadableStreamDataConsumerHandleTest, Read) {
- ScriptState::Scope scope(getScriptState());
- ScriptValue stream(
- getScriptState(),
- evalWithPrintingError(
- "var controller;"
- "var stream = new ReadableStream({start: c => controller = c});"
- "controller.enqueue(new Uint8Array());"
- "controller.enqueue(new Uint8Array([0x43, 0x44, 0x45, 0x46]));"
- "controller.enqueue(new Uint8Array([0x47, 0x48, 0x49, 0x4a]));"
- "controller.close();"
- "stream"));
- ASSERT_FALSE(stream.isEmpty());
- std::unique_ptr<ReadableStreamDataConsumerHandle> handle =
- createHandle(stream);
- ASSERT_TRUE(handle);
- Persistent<MockClient> client = MockClient::create();
- Checkpoint checkpoint;
-
- InSequence s;
- EXPECT_CALL(checkpoint, Call(1));
- EXPECT_CALL(*client, didGetReadable());
- EXPECT_CALL(checkpoint, Call(2));
- EXPECT_CALL(*client, didGetReadable());
- EXPECT_CALL(checkpoint, Call(3));
- EXPECT_CALL(*client, didGetReadable());
- EXPECT_CALL(checkpoint, Call(4));
- EXPECT_CALL(*client, didGetReadable());
- EXPECT_CALL(checkpoint, Call(5));
- EXPECT_CALL(*client, didGetReadable());
- EXPECT_CALL(checkpoint, Call(6));
-
- char buffer[3];
- size_t readBytes;
- std::unique_ptr<FetchDataConsumerHandle::Reader> reader =
- handle->obtainFetchDataReader(client);
- ASSERT_TRUE(reader);
- checkpoint.Call(1);
- testing::runPendingTasks();
- checkpoint.Call(2);
- EXPECT_EQ(kShouldWait, reader->read(buffer, 3, kNone, &readBytes));
- testing::runPendingTasks();
- checkpoint.Call(3);
- EXPECT_EQ(kShouldWait, reader->read(buffer, 3, kNone, &readBytes));
- testing::runPendingTasks();
- checkpoint.Call(4);
- EXPECT_EQ(kOk, reader->read(buffer, 3, kNone, &readBytes));
- EXPECT_EQ(3u, readBytes);
- EXPECT_EQ(0x43, buffer[0]);
- EXPECT_EQ(0x44, buffer[1]);
- EXPECT_EQ(0x45, buffer[2]);
- EXPECT_EQ(kOk, reader->read(buffer, 3, kNone, &readBytes));
- EXPECT_EQ(1u, readBytes);
- EXPECT_EQ(0x46, buffer[0]);
- EXPECT_EQ(kShouldWait, reader->read(buffer, 3, kNone, &readBytes));
- testing::runPendingTasks();
- checkpoint.Call(5);
- EXPECT_EQ(kOk, reader->read(buffer, 3, kNone, &readBytes));
- EXPECT_EQ(3u, readBytes);
- EXPECT_EQ(0x47, buffer[0]);
- EXPECT_EQ(0x48, buffer[1]);
- EXPECT_EQ(0x49, buffer[2]);
- EXPECT_EQ(kOk, reader->read(buffer, 3, kNone, &readBytes));
- EXPECT_EQ(1u, readBytes);
- EXPECT_EQ(0x4a, buffer[0]);
- EXPECT_EQ(kShouldWait, reader->read(buffer, 3, kNone, &readBytes));
- testing::runPendingTasks();
- checkpoint.Call(6);
- EXPECT_EQ(kDone, reader->read(buffer, 3, kNone, &readBytes));
-}
-
-TEST_F(ReadableStreamDataConsumerHandleTest, TwoPhaseRead) {
- ScriptState::Scope scope(getScriptState());
- ScriptValue stream(
- getScriptState(),
- evalWithPrintingError(
- "var controller;"
- "var stream = new ReadableStream({start: c => controller = c});"
- "controller.enqueue(new Uint8Array());"
- "controller.enqueue(new Uint8Array([0x43, 0x44, 0x45, 0x46]));"
- "controller.enqueue(new Uint8Array([0x47, 0x48, 0x49, 0x4a]));"
- "controller.close();"
- "stream"));
- ASSERT_FALSE(stream.isEmpty());
- std::unique_ptr<ReadableStreamDataConsumerHandle> handle =
- createHandle(stream);
- ASSERT_TRUE(handle);
- Persistent<MockClient> client = MockClient::create();
- Checkpoint checkpoint;
-
- InSequence s;
- EXPECT_CALL(checkpoint, Call(1));
- EXPECT_CALL(*client, didGetReadable());
- EXPECT_CALL(checkpoint, Call(2));
- EXPECT_CALL(*client, didGetReadable());
- EXPECT_CALL(checkpoint, Call(3));
- EXPECT_CALL(*client, didGetReadable());
- EXPECT_CALL(checkpoint, Call(4));
- EXPECT_CALL(*client, didGetReadable());
- EXPECT_CALL(checkpoint, Call(5));
- EXPECT_CALL(*client, didGetReadable());
- EXPECT_CALL(checkpoint, Call(6));
-
- const void* buffer;
- size_t available;
- std::unique_ptr<FetchDataConsumerHandle::Reader> reader =
- handle->obtainFetchDataReader(client);
- ASSERT_TRUE(reader);
- checkpoint.Call(1);
- testing::runPendingTasks();
- checkpoint.Call(2);
- EXPECT_EQ(kShouldWait, reader->beginRead(&buffer, kNone, &available));
- testing::runPendingTasks();
- checkpoint.Call(3);
- EXPECT_EQ(kShouldWait, reader->beginRead(&buffer, kNone, &available));
- testing::runPendingTasks();
- checkpoint.Call(4);
- EXPECT_EQ(kOk, reader->beginRead(&buffer, kNone, &available));
- EXPECT_EQ(4u, available);
- EXPECT_EQ(0x43, static_cast<const char*>(buffer)[0]);
- EXPECT_EQ(0x44, static_cast<const char*>(buffer)[1]);
- EXPECT_EQ(0x45, static_cast<const char*>(buffer)[2]);
- EXPECT_EQ(0x46, static_cast<const char*>(buffer)[3]);
- EXPECT_EQ(kOk, reader->endRead(0));
- EXPECT_EQ(kOk, reader->beginRead(&buffer, kNone, &available));
- EXPECT_EQ(4u, available);
- EXPECT_EQ(0x43, static_cast<const char*>(buffer)[0]);
- EXPECT_EQ(0x44, static_cast<const char*>(buffer)[1]);
- EXPECT_EQ(0x45, static_cast<const char*>(buffer)[2]);
- EXPECT_EQ(0x46, static_cast<const char*>(buffer)[3]);
- EXPECT_EQ(kOk, reader->endRead(1));
- EXPECT_EQ(kOk, reader->beginRead(&buffer, kNone, &available));
- EXPECT_EQ(3u, available);
- EXPECT_EQ(0x44, static_cast<const char*>(buffer)[0]);
- EXPECT_EQ(0x45, static_cast<const char*>(buffer)[1]);
- EXPECT_EQ(0x46, static_cast<const char*>(buffer)[2]);
- EXPECT_EQ(kOk, reader->endRead(3));
- EXPECT_EQ(kShouldWait, reader->beginRead(&buffer, kNone, &available));
- testing::runPendingTasks();
- checkpoint.Call(5);
- EXPECT_EQ(kOk, reader->beginRead(&buffer, kNone, &available));
- EXPECT_EQ(4u, available);
- EXPECT_EQ(0x47, static_cast<const char*>(buffer)[0]);
- EXPECT_EQ(0x48, static_cast<const char*>(buffer)[1]);
- EXPECT_EQ(0x49, static_cast<const char*>(buffer)[2]);
- EXPECT_EQ(0x4a, static_cast<const char*>(buffer)[3]);
- EXPECT_EQ(kOk, reader->endRead(4));
- EXPECT_EQ(kShouldWait, reader->beginRead(&buffer, kNone, &available));
- testing::runPendingTasks();
- checkpoint.Call(6);
- EXPECT_EQ(kDone, reader->beginRead(&buffer, kNone, &available));
-}
-
-TEST_F(ReadableStreamDataConsumerHandleTest, EnqueueUndefined) {
- ScriptState::Scope scope(getScriptState());
- ScriptValue stream(
- getScriptState(),
- evalWithPrintingError(
- "var controller;"
- "var stream = new ReadableStream({start: c => controller = c});"
- "controller.enqueue(undefined);"
- "controller.close();"
- "stream"));
- ASSERT_FALSE(stream.isEmpty());
- std::unique_ptr<ReadableStreamDataConsumerHandle> handle =
- createHandle(stream);
- ASSERT_TRUE(handle);
- Persistent<MockClient> client = MockClient::create();
- Checkpoint checkpoint;
-
- InSequence s;
- EXPECT_CALL(checkpoint, Call(1));
- EXPECT_CALL(*client, didGetReadable());
- EXPECT_CALL(checkpoint, Call(2));
- EXPECT_CALL(*client, didGetReadable());
- EXPECT_CALL(checkpoint, Call(3));
-
- const void* buffer;
- size_t available;
- std::unique_ptr<FetchDataConsumerHandle::Reader> reader =
- handle->obtainFetchDataReader(client);
- ASSERT_TRUE(reader);
- checkpoint.Call(1);
- testing::runPendingTasks();
- checkpoint.Call(2);
- EXPECT_EQ(kShouldWait, reader->beginRead(&buffer, kNone, &available));
- testing::runPendingTasks();
- checkpoint.Call(3);
- EXPECT_EQ(kUnexpectedError, reader->beginRead(&buffer, kNone, &available));
-}
-
-TEST_F(ReadableStreamDataConsumerHandleTest, EnqueueNull) {
- ScriptState::Scope scope(getScriptState());
- ScriptValue stream(
- getScriptState(),
- evalWithPrintingError(
- "var controller;"
- "var stream = new ReadableStream({start: c => controller = c});"
- "controller.enqueue(null);"
- "controller.close();"
- "stream"));
- ASSERT_FALSE(stream.isEmpty());
- std::unique_ptr<ReadableStreamDataConsumerHandle> handle =
- createHandle(stream);
- ASSERT_TRUE(handle);
- Persistent<MockClient> client = MockClient::create();
- Checkpoint checkpoint;
-
- InSequence s;
- EXPECT_CALL(checkpoint, Call(1));
- EXPECT_CALL(*client, didGetReadable());
- EXPECT_CALL(checkpoint, Call(2));
- EXPECT_CALL(*client, didGetReadable());
- EXPECT_CALL(checkpoint, Call(3));
-
- const void* buffer;
- size_t available;
- std::unique_ptr<FetchDataConsumerHandle::Reader> reader =
- handle->obtainFetchDataReader(client);
- ASSERT_TRUE(reader);
- checkpoint.Call(1);
- testing::runPendingTasks();
- checkpoint.Call(2);
- EXPECT_EQ(kShouldWait, reader->beginRead(&buffer, kNone, &available));
- testing::runPendingTasks();
- checkpoint.Call(3);
- EXPECT_EQ(kUnexpectedError, reader->beginRead(&buffer, kNone, &available));
-}
-
-TEST_F(ReadableStreamDataConsumerHandleTest, EnqueueString) {
- ScriptState::Scope scope(getScriptState());
- ScriptValue stream(
- getScriptState(),
- evalWithPrintingError(
- "var controller;"
- "var stream = new ReadableStream({start: c => controller = c});"
- "controller.enqueue('hello');"
- "controller.close();"
- "stream"));
- ASSERT_FALSE(stream.isEmpty());
- std::unique_ptr<ReadableStreamDataConsumerHandle> handle =
- createHandle(stream);
- ASSERT_TRUE(handle);
- Persistent<MockClient> client = MockClient::create();
- Checkpoint checkpoint;
-
- InSequence s;
- EXPECT_CALL(checkpoint, Call(1));
- EXPECT_CALL(*client, didGetReadable());
- EXPECT_CALL(checkpoint, Call(2));
- EXPECT_CALL(*client, didGetReadable());
- EXPECT_CALL(checkpoint, Call(3));
-
- const void* buffer;
- size_t available;
- std::unique_ptr<FetchDataConsumerHandle::Reader> reader =
- handle->obtainFetchDataReader(client);
- ASSERT_TRUE(reader);
- checkpoint.Call(1);
- testing::runPendingTasks();
- checkpoint.Call(2);
- EXPECT_EQ(kShouldWait, reader->beginRead(&buffer, kNone, &available));
- testing::runPendingTasks();
- checkpoint.Call(3);
- EXPECT_EQ(kUnexpectedError, reader->beginRead(&buffer, kNone, &available));
-}
-
-TEST_F(ReadableStreamDataConsumerHandleTest, StreamReaderShouldBeWeak) {
- std::unique_ptr<FetchDataConsumerHandle::Reader> reader;
- Checkpoint checkpoint;
- Persistent<MockClient> client = MockClient::create();
- ScriptValue stream;
-
- InSequence s;
- EXPECT_CALL(checkpoint, Call(1));
- EXPECT_CALL(*client, didGetReadable());
- EXPECT_CALL(checkpoint, Call(2));
- EXPECT_CALL(checkpoint, Call(3));
- EXPECT_CALL(*client, didGetReadable());
- EXPECT_CALL(checkpoint, Call(4));
-
- {
- // We need this scope to collect local handles.
- ScriptState::Scope scope(getScriptState());
- stream = ScriptValue(getScriptState(),
- evalWithPrintingError("new ReadableStream()"));
- ASSERT_FALSE(stream.isEmpty());
- std::unique_ptr<ReadableStreamDataConsumerHandle> handle =
- createHandle(stream);
- ASSERT_TRUE(handle);
-
- reader = handle->obtainFetchDataReader(client);
- ASSERT_TRUE(reader);
- }
-
- checkpoint.Call(1);
- testing::runPendingTasks();
- checkpoint.Call(2);
- stream.clear();
- gc();
- checkpoint.Call(3);
- testing::runPendingTasks();
-
- checkpoint.Call(4);
- const void* buffer;
- size_t available;
- EXPECT_EQ(kUnexpectedError, reader->beginRead(&buffer, kNone, &available));
-}
-
-TEST_F(ReadableStreamDataConsumerHandleTest,
- StreamReaderShouldBeWeakWhenReading) {
- std::unique_ptr<FetchDataConsumerHandle::Reader> reader;
- Checkpoint checkpoint;
- Persistent<MockClient> client = MockClient::create();
- ScriptValue stream;
-
- InSequence s;
- EXPECT_CALL(checkpoint, Call(1));
- EXPECT_CALL(*client, didGetReadable());
- EXPECT_CALL(checkpoint, Call(2));
- EXPECT_CALL(checkpoint, Call(3));
- EXPECT_CALL(checkpoint, Call(4));
- EXPECT_CALL(*client, didGetReadable());
- EXPECT_CALL(checkpoint, Call(5));
-
- {
- // We need this scope to collect local handles.
- ScriptState::Scope scope(getScriptState());
- stream = ScriptValue(getScriptState(),
- evalWithPrintingError("new ReadableStream()"));
- ASSERT_FALSE(stream.isEmpty());
- std::unique_ptr<ReadableStreamDataConsumerHandle> handle =
- createHandle(stream);
- ASSERT_TRUE(handle);
-
- reader = handle->obtainFetchDataReader(client);
- ASSERT_TRUE(reader);
- }
-
- const void* buffer;
- size_t available;
- checkpoint.Call(1);
- testing::runPendingTasks();
- checkpoint.Call(2);
- EXPECT_EQ(kShouldWait, reader->beginRead(&buffer, kNone, &available));
-
- testing::runPendingTasks();
- checkpoint.Call(3);
- stream.clear();
- gc();
- checkpoint.Call(4);
- testing::runPendingTasks();
-
- checkpoint.Call(5);
- EXPECT_EQ(kUnexpectedError, reader->beginRead(&buffer, kNone, &available));
-}
-
-} // namespace
-
-} // namespace blink
« no previous file with comments | « third_party/WebKit/Source/modules/fetch/ReadableStreamDataConsumerHandle.cpp ('k') | third_party/WebKit/Source/modules/fetch/Response.cpp » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698