content: Use base::MessageLoop.

content/browser/streams/stream_url_request_job_unittest.cc

 // Copyright (c) 2012 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 "base/message_loop.h"
 #include "base/test/test_simple_task_runner.h"
 #include "content/browser/streams/stream.h"
 #include "content/browser/streams/stream_registry.h"
 #include "content/browser/streams/stream_url_request_job.h"
 #include "content/browser/streams/stream_write_observer.h"
@@ skipping 31 matching lines @@
       scoped_refptr<Stream> stream = registry_->GetStream(request->url());
       if (stream)
         return new StreamURLRequestJob(request, network_delegate, stream);
       return NULL;
     }
 
    private:
     StreamRegistry* registry_;
   };
 
-  StreamURLRequestJobTest()
-      : message_loop_(MessageLoop::TYPE_IO) {
-  }
+  StreamURLRequestJobTest() : message_loop_(base::MessageLoop::TYPE_IO) {}
 
   virtual void SetUp() {
     registry_.reset(new StreamRegistry());
 
     url_request_job_factory_.SetProtocolHandler(
         "blob", new MockProtocolHandler(registry_.get()));
     url_request_context_.set_job_factory(&url_request_job_factory_);
   }
 
   virtual void TearDown() {
   }
 
   void TestSuccessRequest(const GURL& url,
                           const std::string& expected_response) {
     TestRequest("GET", url, net::HttpRequestHeaders(), 200, expected_response);
   }
 
   void TestRequest(const std::string& method,
                    const GURL& url,
                    const net::HttpRequestHeaders& extra_headers,
                    int expected_status_code,
                    const std::string& expected_response) {
     net::TestDelegate delegate;
     request_.reset(url_request_context_.CreateRequest(url, &delegate));
     request_->set_method(method);
     if (!extra_headers.IsEmpty())
       request_->SetExtraRequestHeaders(extra_headers);
     request_->Start();
 
-    MessageLoop::current()->RunUntilIdle();
+    base::MessageLoop::current()->RunUntilIdle();
 
     // Verify response.
     EXPECT_TRUE(request_->status().is_success());
     EXPECT_EQ(expected_status_code,
               request_->response_headers()->response_code());
     EXPECT_EQ(expected_response, delegate.data_received());
   }
 
  protected:
-  MessageLoop message_loop_;
+  base::MessageLoop message_loop_;
   scoped_ptr<StreamRegistry> registry_;
 
   net::URLRequestContext url_request_context_;
   net::URLRequestJobFactoryImpl url_request_job_factory_;
   scoped_ptr<net::URLRequest> request_;
 };
 
 TEST_F(StreamURLRequestJobTest, TestGetSimpleDataRequest) {
   scoped_refptr<Stream> stream(
       new Stream(registry_.get(), NULL, GURL(), kStreamURL));
@@ skipping 23 matching lines @@
   stream->Finalize();
   TestSuccessRequest(kStreamURL, large_data);
 }
 
 TEST_F(StreamURLRequestJobTest, TestGetNonExistentStreamRequest) {
   net::TestDelegate delegate;
   request_.reset(url_request_context_.CreateRequest(kStreamURL, &delegate));
   request_->set_method("GET");
   request_->Start();
 
-  MessageLoop::current()->RunUntilIdle();
+  base::MessageLoop::current()->RunUntilIdle();
 
   // Verify response.
   EXPECT_FALSE(request_->status().is_success());
 }
 
 TEST_F(StreamURLRequestJobTest, TestRangeDataRequest) {
   scoped_refptr<Stream> stream(
       new Stream(registry_.get(), NULL, GURL(), kStreamURL));
 
   scoped_refptr<net::StringIOBuffer> buffer(
@@ skipping 17 matching lines @@
 
   stream->AddData(buffer, buffer->size());
   stream->Finalize();
 
   net::HttpRequestHeaders extra_headers;
   extra_headers.SetHeader(net::HttpRequestHeaders::kRange, "bytes=1-3");
   TestRequest("GET", kStreamURL, extra_headers, 405, std::string());
 }
 
 }  // namespace content