EDK: Make ConnectionManagerTest not use base::MessageLoop/RunLoop.

mojo/edk/base_edk/platform_message_loop_impl_unittest.cc

 // 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 "mojo/edk/base_edk/platform_message_loop_impl.h"
 
 #include <memory>
 #include <thread>
 #include <vector>
 
@@ skipping 51 matching lines @@
   task_runner->PostTask(ToClosure([&stuff, &message_loop, &task_runner]() {
     EXPECT_TRUE(message_loop.IsRunningOnCurrentThread());
     stuff.push_back(4);
     task_runner->PostTask(ToClosure([&stuff]() { stuff.push_back(6); }));
   }));
   task_runner->PostTask(ToClosure([&stuff]() { stuff.push_back(5); }));
   message_loop.RunUntilIdle();
   EXPECT_EQ(std::vector<int>({4, 5, 6}), stuff);
 
   stuff.clear();
+  task_runner->PostTask(ToClosure([&stuff, &message_loop, &task_runner]() {
+    EXPECT_TRUE(message_loop.IsRunningOnCurrentThread());
+    stuff.push_back(7);
+    message_loop.QuitNow();
+    task_runner->PostTask(ToClosure([&stuff]() { stuff.push_back(9); }));
+  }));
+  task_runner->PostTask(ToClosure([&stuff]() { stuff.push_back(8); }));
+  message_loop.Run();
+  EXPECT_EQ(std::vector<int>({7}), stuff);
+  stuff.clear();
+  message_loop.RunUntilIdle();
+  EXPECT_EQ(std::vector<int>({8, 9}), stuff);
+
+  stuff.clear();
   message_loop.RunUntilIdle();
   EXPECT_TRUE(stuff.empty());
 
   {
     std::thread other_thread([&message_loop]() {
       // |IsRunningOnCurrentThread()| may be called on any thread.
       EXPECT_FALSE(message_loop.IsRunningOnCurrentThread());
     });
     other_thread.join();
   }
 
   stuff.clear();
   task_runner->PostTask(ToClosure([&stuff, &message_loop, &task_runner]() {
     EXPECT_TRUE(message_loop.IsRunningOnCurrentThread());
     std::thread other_thread([&stuff, &message_loop, task_runner]() {
       EXPECT_FALSE(message_loop.IsRunningOnCurrentThread());
       EXPECT_EQ(task_runner, message_loop.GetTaskRunner());
-      stuff.push_back(7);
+      stuff.push_back(10);
       task_runner->PostTask(ToClosure([&stuff, &message_loop]() {
         EXPECT_TRUE(message_loop.IsRunningOnCurrentThread());
-        stuff.push_back(8);
+        stuff.push_back(11);
         message_loop.QuitWhenIdle();
       }));
     });
     other_thread.join();
-    EXPECT_EQ(std::vector<int>({7}), stuff);
+    EXPECT_EQ(std::vector<int>({10}), stuff);
     stuff.clear();
   }));
   message_loop.Run();
-  EXPECT_EQ(std::vector<int>({8}), stuff);
+  EXPECT_EQ(std::vector<int>({11}), stuff);
 }
 
 TEST(PlatformMessageLoopImpl, TypeIO) {
   PlatformMessageLoopImpl message_loop(base::MessageLoop::TYPE_IO);
 
   EXPECT_EQ(base::MessageLoop::TYPE_IO,
             message_loop.base_message_loop().type());
 
   RefPtr<TaskRunner> task_runner = message_loop.GetTaskRunner();
   EXPECT_TRUE(task_runner);
@@ skipping 31 matching lines @@
   bool was_run = false;
   message_loop->GetTaskRunner()->PostTask(
       ToClosure([&was_run]() { was_run = true; }));
   EXPECT_FALSE(was_run);
   message_loop->RunUntilIdle();
   EXPECT_TRUE(was_run);
 }
 
 }  // namespace
 }  // namespace base_edk