Index: content/browser/loader/upload_data_stream_builder_unittest.cc |
diff --git a/content/browser/loader/upload_data_stream_builder_unittest.cc b/content/browser/loader/upload_data_stream_builder_unittest.cc |
index 174a89bff0d43928cc57c42cced202d5cca5ab94..57161eaf4caf1a281d91b2c5fd020e2c192f5f39 100644 |
--- a/content/browser/loader/upload_data_stream_builder_unittest.cc |
+++ b/content/browser/loader/upload_data_stream_builder_unittest.cc |
@@ -9,8 +9,9 @@ |
#include "base/files/file_path.h" |
#include "base/files/file_util.h" |
+#include "base/message_loop/message_loop.h" |
+#include "base/message_loop/message_loop_proxy.h" |
#include "base/run_loop.h" |
-#include "base/thread_task_runner_handle.h" |
#include "base/time/time.h" |
#include "content/common/resource_request_body.h" |
#include "net/base/io_buffer.h" |
@@ -77,8 +78,7 @@ TEST(UploadDataStreamBuilderTest, CreateUploadDataStreamWithoutBlob) { |
request_body->set_identifier(kIdentifier); |
scoped_ptr<net::UploadDataStream> upload(UploadDataStreamBuilder::Build( |
- request_body.get(), NULL, NULL, |
- base::ThreadTaskRunnerHandle::Get().get())); |
+ request_body.get(), NULL, NULL, base::MessageLoopProxy::current().get())); |
EXPECT_EQ(kIdentifier, upload->identifier()); |
ASSERT_TRUE(upload->GetElementReaders()); |
@@ -146,9 +146,12 @@ TEST(UploadDataStreamBuilderTest, ResolveBlobAndCreateUploadDataStream) { |
upload_element2.length(), |
upload_element2.expected_modification_time()); |
- scoped_ptr<net::UploadDataStream> upload(UploadDataStreamBuilder::Build( |
- request_body.get(), &blob_storage_context, NULL, |
- base::ThreadTaskRunnerHandle::Get().get())); |
+ scoped_ptr<net::UploadDataStream> upload( |
+ UploadDataStreamBuilder::Build( |
+ request_body.get(), |
+ &blob_storage_context, |
+ NULL, |
+ base::MessageLoopProxy::current().get())); |
ASSERT_TRUE(upload->GetElementReaders()); |
ASSERT_EQ(2U, upload->GetElementReaders()->size()); |
@@ -162,8 +165,10 @@ TEST(UploadDataStreamBuilderTest, ResolveBlobAndCreateUploadDataStream) { |
request_body->AppendBlob(blob_id0); |
upload = UploadDataStreamBuilder::Build( |
- request_body.get(), &blob_storage_context, NULL, |
- base::ThreadTaskRunnerHandle::Get().get()); |
+ request_body.get(), |
+ &blob_storage_context, |
+ NULL, |
+ base::MessageLoopProxy::current().get()); |
ASSERT_TRUE(upload->GetElementReaders()); |
ASSERT_EQ(0U, upload->GetElementReaders()->size()); |
@@ -172,8 +177,10 @@ TEST(UploadDataStreamBuilderTest, ResolveBlobAndCreateUploadDataStream) { |
request_body->AppendBlob(blob_id1); |
upload = UploadDataStreamBuilder::Build( |
- request_body.get(), &blob_storage_context, NULL, |
- base::ThreadTaskRunnerHandle::Get().get()); |
+ request_body.get(), |
+ &blob_storage_context, |
+ NULL, |
+ base::MessageLoopProxy::current().get()); |
ASSERT_TRUE(upload->GetElementReaders()); |
ASSERT_EQ(2U, upload->GetElementReaders()->size()); |
EXPECT_TRUE(AreElementsEqual( |
@@ -194,8 +201,10 @@ TEST(UploadDataStreamBuilderTest, ResolveBlobAndCreateUploadDataStream) { |
upload_element2.expected_modification_time()); |
upload = UploadDataStreamBuilder::Build( |
- request_body.get(), &blob_storage_context, NULL, |
- base::ThreadTaskRunnerHandle::Get().get()); |
+ request_body.get(), |
+ &blob_storage_context, |
+ NULL, |
+ base::MessageLoopProxy::current().get()); |
ASSERT_TRUE(upload->GetElementReaders()); |
ASSERT_EQ(4U, upload->GetElementReaders()->size()); |
EXPECT_TRUE(AreElementsEqual( |
@@ -219,9 +228,11 @@ TEST(UploadDataStreamBuilderTest, ResolveBlobAndCreateUploadDataStream) { |
upload_element2.expected_modification_time()); |
request_body->AppendBlob(blob_id1); |
- upload = UploadDataStreamBuilder::Build( |
- request_body.get(), &blob_storage_context, NULL, |
- base::ThreadTaskRunnerHandle::Get().get()); |
+ upload = |
+ UploadDataStreamBuilder::Build(request_body.get(), |
+ &blob_storage_context, |
+ NULL, |
+ base::MessageLoopProxy::current().get()); |
ASSERT_TRUE(upload->GetElementReaders()); |
ASSERT_EQ(4U, upload->GetElementReaders()->size()); |
EXPECT_TRUE(AreElementsEqual( |
@@ -246,8 +257,10 @@ TEST(UploadDataStreamBuilderTest, ResolveBlobAndCreateUploadDataStream) { |
upload_element2.expected_modification_time()); |
upload = UploadDataStreamBuilder::Build( |
- request_body.get(), &blob_storage_context, NULL, |
- base::ThreadTaskRunnerHandle::Get().get()); |
+ request_body.get(), |
+ &blob_storage_context, |
+ NULL, |
+ base::MessageLoopProxy::current().get()); |
ASSERT_TRUE(upload->GetElementReaders()); |
ASSERT_EQ(4U, upload->GetElementReaders()->size()); |
EXPECT_TRUE(AreElementsEqual( |
@@ -274,8 +287,10 @@ TEST(UploadDataStreamBuilderTest, ResolveBlobAndCreateUploadDataStream) { |
upload_element2.expected_modification_time()); |
upload = UploadDataStreamBuilder::Build( |
- request_body.get(), &blob_storage_context, NULL, |
- base::ThreadTaskRunnerHandle::Get().get()); |
+ request_body.get(), |
+ &blob_storage_context, |
+ NULL, |
+ base::MessageLoopProxy::current().get()); |
ASSERT_TRUE(upload->GetElementReaders()); |
ASSERT_EQ(8U, upload->GetElementReaders()->size()); |
EXPECT_TRUE(AreElementsEqual( |
@@ -326,7 +341,7 @@ TEST(UploadDataStreamBuilderTest, |
scoped_refptr<ResourceRequestBody> request_body(new ResourceRequestBody()); |
scoped_ptr<net::UploadDataStream> upload(UploadDataStreamBuilder::Build( |
request_body.get(), &blob_storage_context, NULL, |
- base::ThreadTaskRunnerHandle::Get().get())); |
+ base::MessageLoopProxy::current().get())); |
request_body = new ResourceRequestBody(); |
request_body->AppendBlob(blob_id); |
@@ -335,7 +350,7 @@ TEST(UploadDataStreamBuilderTest, |
upload = UploadDataStreamBuilder::Build( |
request_body.get(), &blob_storage_context, NULL, |
- base::ThreadTaskRunnerHandle::Get().get()); |
+ base::MessageLoopProxy::current().get()); |
ASSERT_TRUE(upload->GetElementReaders()); |
const auto& readers = *upload->GetElementReaders(); |
ASSERT_EQ(3U, readers.size()); |