Index: mojo/edk/system/data_pipe_consumer_dispatcher.h |
diff --git a/mojo/edk/system/data_pipe_consumer_dispatcher.h b/mojo/edk/system/data_pipe_consumer_dispatcher.h |
index 8a541a84ab9d4a2fb6c308c311ca20b617834b4d..746d02e4d3aafe75764fcf98fb72ae86ccdb8369 100644 |
--- a/mojo/edk/system/data_pipe_consumer_dispatcher.h |
+++ b/mojo/edk/system/data_pipe_consumer_dispatcher.h |
@@ -7,6 +7,7 @@ |
#include "base/memory/ref_counted.h" |
#include "mojo/edk/system/dispatcher.h" |
+#include "mojo/edk/system/ref_ptr.h" |
#include "mojo/public/cpp/system/macros.h" |
namespace mojo { |
@@ -24,7 +25,7 @@ class DataPipeConsumerDispatcher final : public Dispatcher { |
} |
// Must be called before any other methods. |
- void Init(scoped_refptr<DataPipe> data_pipe) MOJO_NOT_THREAD_SAFE; |
+ void Init(RefPtr<DataPipe>&& data_pipe) MOJO_NOT_THREAD_SAFE; |
// |Dispatcher| public methods: |
Type GetType() const override; |
@@ -73,7 +74,7 @@ class DataPipeConsumerDispatcher final : public Dispatcher { |
bool IsBusyNoLock() const override; |
// This will be null if closed. |
- scoped_refptr<DataPipe> data_pipe_ MOJO_GUARDED_BY(mutex()); |
+ RefPtr<DataPipe> data_pipe_ MOJO_GUARDED_BY(mutex()); |
MOJO_DISALLOW_COPY_AND_ASSIGN(DataPipeConsumerDispatcher); |
}; |