Index: third_party/mojo/src/mojo/public/cpp/bindings/tests/connector_unittest.cc |
diff --git a/third_party/mojo/src/mojo/public/cpp/bindings/tests/connector_unittest.cc b/third_party/mojo/src/mojo/public/cpp/bindings/tests/connector_unittest.cc |
index febc72e90ef30a4d9793553e900ddd44d9215a16..c62794e723e6312fb7b8d07da9de80e33aee90ea 100644 |
--- a/third_party/mojo/src/mojo/public/cpp/bindings/tests/connector_unittest.cc |
+++ b/third_party/mojo/src/mojo/public/cpp/bindings/tests/connector_unittest.cc |
@@ -5,12 +5,12 @@ |
#include <stdlib.h> |
#include <string.h> |
-#include "base/message_loop/message_loop.h" |
-#include "mojo/message_pump/message_pump_mojo.h" |
#include "mojo/public/cpp/bindings/lib/connector.h" |
#include "mojo/public/cpp/bindings/lib/message_builder.h" |
#include "mojo/public/cpp/bindings/tests/message_queue.h" |
+#include "mojo/public/cpp/environment/environment.h" |
#include "mojo/public/cpp/system/macros.h" |
+#include "mojo/public/cpp/utility/run_loop.h" |
#include "testing/gtest/include/gtest/gtest.h" |
namespace mojo { |
@@ -73,7 +73,7 @@ |
class ConnectorTest : public testing::Test { |
public: |
- ConnectorTest() : loop_(common::MessagePumpMojo::Create()) {} |
+ ConnectorTest() {} |
void SetUp() override { |
CreateMessagePipe(nullptr, &handle0_, &handle1_); |
@@ -96,7 +96,8 @@ |
ScopedMessagePipeHandle handle1_; |
private: |
- base::MessageLoop loop_; |
+ Environment env_; |
+ RunLoop loop_; |
}; |
TEST_F(ConnectorTest, Basic) { |
@@ -248,7 +249,7 @@ |
// Close the other end of the pipe. |
handle1_.reset(); |
- // Not observed yet because we haven't spun the message loop yet. |
+ // Not observed yet because we haven't spun the RunLoop yet. |
EXPECT_FALSE(connector0.encountered_error()); |
// Write failures are not reported. |
@@ -258,7 +259,7 @@ |
// Still not observed. |
EXPECT_FALSE(connector0.encountered_error()); |
- // Spin the message loop, and then we should start observing the closed pipe. |
+ // Spin the RunLoop, and then we should start observing the closed pipe. |
PumpMessages(); |
EXPECT_TRUE(connector0.encountered_error()); |