EDK: Add a TestIOThread::IsCurrentAndRunning().

mojo/edk/system/data_pipe_impl_unittest.cc

Index: mojo/edk/system/data_pipe_impl_unittest.cc
diff --git a/mojo/edk/system/data_pipe_impl_unittest.cc b/mojo/edk/system/data_pipe_impl_unittest.cc
index 46e6a187f94886e134a411a2f946793ae578fa3b..0350cc7ed018d72850320b416df193a8213bf64d 100644
--- a/mojo/edk/system/data_pipe_impl_unittest.cc
+++ b/mojo/edk/system/data_pipe_impl_unittest.cc
@@ -14,7 +14,6 @@
 
 #include "base/bind.h"
 #include "base/logging.h"
-#include "base/message_loop/message_loop.h"
 #include "mojo/edk/embedder/platform_channel_pair.h"
 #include "mojo/edk/embedder/simple_platform_support.h"
 #include "mojo/edk/system/channel.h"
@@ -323,7 +322,7 @@ class RemoteDataPipeImplTestHelper : public DataPipeImplTestHelper {
   // currently work correctly with base::Bind.
   void SetUpOnIOThread(RefPtr<ChannelEndpoint> ep0,
                        RefPtr<ChannelEndpoint> ep1) {
-    CHECK_EQ(base::MessageLoop::current(), io_thread_.message_loop());
+    CHECK(io_thread_.IsCurrentAndRunning());
 
     embedder::PlatformChannelPair channel_pair;
     channels_[0] = MakeRefCounted<Channel>(&platform_support_);
@@ -335,7 +334,7 @@ class RemoteDataPipeImplTestHelper : public DataPipeImplTestHelper {
   }
 
   void TearDownOnIOThread() {
-    CHECK_EQ(base::MessageLoop::current(), io_thread_.message_loop());
+    CHECK(io_thread_.IsCurrentAndRunning());
 
     if (channels_[0]) {
       channels_[0]->Shutdown();