summaryrefslogtreecommitdiffstats
path: root/content/browser/streams
diff options
context:
space:
mode:
Diffstat (limited to 'content/browser/streams')
-rw-r--r--content/browser/streams/stream_unittest.cc4
-rw-r--r--content/browser/streams/stream_url_request_job.cc2
-rw-r--r--content/browser/streams/stream_url_request_job_unittest.cc10
3 files changed, 7 insertions, 9 deletions
diff --git a/content/browser/streams/stream_unittest.cc b/content/browser/streams/stream_unittest.cc
index 2c9f34c..3452553 100644
--- a/content/browser/streams/stream_unittest.cc
+++ b/content/browser/streams/stream_unittest.cc
@@ -32,7 +32,7 @@ class StreamTest : public testing::Test {
}
protected:
- MessageLoop message_loop_;
+ base::MessageLoop message_loop_;
scoped_ptr<StreamRegistry> registry_;
private:
@@ -138,7 +138,7 @@ TEST_F(StreamTest, Stream) {
writer.Write(stream, buffer, kBufferSize);
stream->Finalize();
reader.Read(stream);
- MessageLoop::current()->RunUntilIdle();
+ base::MessageLoop::current()->RunUntilIdle();
ASSERT_EQ(reader.buffer()->capacity(), kBufferSize);
for (int i = 0; i < kBufferSize; i++)
diff --git a/content/browser/streams/stream_url_request_job.cc b/content/browser/streams/stream_url_request_job.cc
index 85e1a6d..4478d16 100644
--- a/content/browser/streams/stream_url_request_job.cc
+++ b/content/browser/streams/stream_url_request_job.cc
@@ -72,7 +72,7 @@ void StreamURLRequestJob::OnDataAvailable(Stream* stream) {
// net::URLRequestJob methods.
void StreamURLRequestJob::Start() {
// Continue asynchronously.
- MessageLoop::current()->PostTask(
+ base::MessageLoop::current()->PostTask(
FROM_HERE,
base::Bind(&StreamURLRequestJob::DidStart, weak_factory_.GetWeakPtr()));
}
diff --git a/content/browser/streams/stream_url_request_job_unittest.cc b/content/browser/streams/stream_url_request_job_unittest.cc
index bed96fa..37d9c4f 100644
--- a/content/browser/streams/stream_url_request_job_unittest.cc
+++ b/content/browser/streams/stream_url_request_job_unittest.cc
@@ -49,9 +49,7 @@ class StreamURLRequestJobTest : public testing::Test {
StreamRegistry* registry_;
};
- StreamURLRequestJobTest()
- : message_loop_(MessageLoop::TYPE_IO) {
- }
+ StreamURLRequestJobTest() : message_loop_(base::MessageLoop::TYPE_IO) {}
virtual void SetUp() {
registry_.reset(new StreamRegistry());
@@ -81,7 +79,7 @@ class StreamURLRequestJobTest : public testing::Test {
request_->SetExtraRequestHeaders(extra_headers);
request_->Start();
- MessageLoop::current()->RunUntilIdle();
+ base::MessageLoop::current()->RunUntilIdle();
// Verify response.
EXPECT_TRUE(request_->status().is_success());
@@ -91,7 +89,7 @@ class StreamURLRequestJobTest : public testing::Test {
}
protected:
- MessageLoop message_loop_;
+ base::MessageLoop message_loop_;
scoped_ptr<StreamRegistry> registry_;
net::URLRequestContext url_request_context_;
@@ -135,7 +133,7 @@ TEST_F(StreamURLRequestJobTest, TestGetNonExistentStreamRequest) {
request_->set_method("GET");
request_->Start();
- MessageLoop::current()->RunUntilIdle();
+ base::MessageLoop::current()->RunUntilIdle();
// Verify response.
EXPECT_FALSE(request_->status().is_success());