| Index: mojo/common/data_pipe_drainer.cc
|
| diff --git a/mojo/common/data_pipe_drainer.cc b/mojo/common/data_pipe_drainer.cc
|
| index 1133e1165b89015a15586c302bb8f42b69809fab..27bd893d8abe185107de105ade3e31a82b80eae6 100644
|
| --- a/mojo/common/data_pipe_drainer.cc
|
| +++ b/mojo/common/data_pipe_drainer.cc
|
| @@ -15,7 +15,10 @@ namespace common {
|
|
|
| DataPipeDrainer::DataPipeDrainer(Client* client,
|
| mojo::ScopedDataPipeConsumerHandle source)
|
| - : client_(client), source_(std::move(source)), weak_factory_(this) {
|
| + : client_(client),
|
| + source_(std::move(source)),
|
| + handle_watcher_(FROM_HERE),
|
| + weak_factory_(this) {
|
| DCHECK(client_);
|
| handle_watcher_.Start(
|
| source_.get(), MOJO_HANDLE_SIGNAL_READABLE,
|
|
|