components: Remove use of MessageLoopProxy and deprecated MessageLoop APIs

components/policy/core/common/cloud/component_cloud_policy_service_unittest.cc

 // Copyright (c) 2013 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 "components/policy/core/common/cloud/component_cloud_policy_service.h"
 
 #include <map>
 #include <string>
 
 #include "base/callback.h"
 #include "base/files/scoped_temp_dir.h"
-#include "base/message_loop/message_loop.h"
 #include "base/run_loop.h"
 #include "base/single_thread_task_runner.h"
 #include "base/stl_util.h"
 #include "base/values.h"
 #include "components/policy/core/common/cloud/cloud_policy_constants.h"
 #include "components/policy/core/common/cloud/mock_cloud_policy_client.h"
 #include "components/policy/core/common/cloud/mock_cloud_policy_store.h"
 #include "components/policy/core/common/cloud/policy_builder.h"
 #include "components/policy/core/common/cloud/resource_cache.h"
 #include "components/policy/core/common/external_data_fetcher.h"
@@ skipping 76 matching lines @@
   ~TestURLRequestContextGetter() override {}
 
   scoped_refptr<base::SingleThreadTaskRunner> task_runner_;
 };
 
 }  // namespace
 
 class ComponentCloudPolicyServiceTest : public testing::Test {
  protected:
   ComponentCloudPolicyServiceTest()
-      : request_context_(
-            new TestURLRequestContextGetter(loop_.message_loop_proxy())),
+      : request_context_(new TestURLRequestContextGetter(loop_.task_runner())),
         cache_(nullptr),
         client_(nullptr),
         core_(GetChromeUserPolicyType(),
               std::string(),
               &store_,
-              loop_.message_loop_proxy()) {}
+              loop_.task_runner()) {}
 
   void SetUp() override {
     ASSERT_TRUE(temp_dir_.CreateUniqueTempDir());
 
     owned_cache_.reset(
-        new ResourceCache(temp_dir_.path(), loop_.message_loop_proxy()));
+        new ResourceCache(temp_dir_.path(), loop_.task_runner()));
     cache_ = owned_cache_.get();
 
     builder_.policy_data().set_policy_type(
         dm_protocol::kChromeExtensionPolicyType);
     builder_.policy_data().set_settings_entity_id(kTestExtension);
     builder_.payload().set_download_url(kTestDownload);
     builder_.payload().set_secure_hash(crypto::SHA256HashString(kTestPolicy));
 
     expected_policy_.Set("Name",
                          POLICY_LEVEL_MANDATORY,
@@ skipping 13 matching lines @@
     RunUntilIdle();
   }
 
   void RunUntilIdle() {
     base::RunLoop().RunUntilIdle();
   }
 
   void Connect() {
     client_ = new MockCloudPolicyClient();
     service_.reset(new ComponentCloudPolicyService(
-        &delegate_,
-        &registry_,
-        &core_,
-        client_,
-        owned_cache_.Pass(),
-        request_context_,
-        loop_.message_loop_proxy(),
-        loop_.message_loop_proxy()));
+        &delegate_, &registry_, &core_, client_, owned_cache_.Pass(),
+        request_context_, loop_.task_runner(), loop_.task_runner()));
 
     client_->SetDMToken(ComponentPolicyBuilder::kFakeToken);
     EXPECT_EQ(1u, client_->types_to_fetch_.size());
     core_.Connect(scoped_ptr<CloudPolicyClient>(client_));
     EXPECT_EQ(2u, client_->types_to_fetch_.size());
 
     // Also initialize the refresh scheduler, so that calls to
     // core()->RefreshSoon() trigger a FetchPolicy() call on the mock |client_|.
     // The |service_| should never trigger new fetches.
     EXPECT_CALL(*client_, FetchPolicy());
@@ skipping 406 matching lines @@
   EXPECT_TRUE(ContainsKey(contents, kTestExtension));
   EXPECT_FALSE(ContainsKey(contents, kTestExtension2));
 
   // And the service isn't publishing policy for the second extension anymore.
   expected_bundle.Clear();
   expected_bundle.Get(ns).CopyFrom(expected_policy_);
   EXPECT_TRUE(service_->policy().Equals(expected_bundle));
 }
 
 }  // namespace policy