Mojo: Armed Watchers

mojo/common/data_pipe_drainer.cc

 // Copyright 2014 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/common/data_pipe_drainer.h"
 
 #include <stdint.h>
 
 #include <utility>
 
 #include "base/bind.h"
 
 namespace mojo {
 namespace common {
 
 DataPipeDrainer::DataPipeDrainer(Client* client,
                                  mojo::ScopedDataPipeConsumerHandle source)
     : client_(client),
       source_(std::move(source)),
-      handle_watcher_(FROM_HERE),
+      handle_watcher_(FROM_HERE, Watcher::ArmingPolicy::AUTOMATIC),
       weak_factory_(this) {
   DCHECK(client_);
   handle_watcher_.Start(
       source_.get(), MOJO_HANDLE_SIGNAL_READABLE,
       base::Bind(&DataPipeDrainer::WaitComplete, weak_factory_.GetWeakPtr()));
 }
 
 DataPipeDrainer::~DataPipeDrainer() {}
 
 void DataPipeDrainer::ReadData() {
@@ skipping 10 matching lines @@
     DCHECK(false) << "Unhandled MojoResult: " << rv;
   }
 }
 
 void DataPipeDrainer::WaitComplete(MojoResult result) {
   ReadData();
 }
 
 }  // namespace common
 }  // namespace mojo