Mojo: Armed Watchers

chrome/browser/media/cast_remoting_sender.h

 // Copyright 2016 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.
 
 #ifndef CHROME_BROWSER_MEDIA_CAST_REMOTING_SENDER_H_
 #define CHROME_BROWSER_MEDIA_CAST_REMOTING_SENDER_H_
 
 #include <queue>
 
 #include "base/callback_forward.h"
 #include "base/memory/weak_ptr.h"
 #include "base/time/time.h"
 #include "media/cast/cast_config.h"
 #include "media/cast/net/cast_transport.h"
 #include "media/cast/net/rtcp/rtcp_defines.h"
 #include "media/mojo/interfaces/remoting.mojom.h"
 #include "mojo/public/cpp/bindings/binding.h"
-#include "mojo/public/cpp/system/watcher.h"
+#include "mojo/public/cpp/system/simple_watcher.h"
 
 namespace cast {
 
 // The callback that is used to send frame events to renderer process for
 // logging purpose.
 using FrameEventCallback =
     base::Callback<void(const std::vector<media::cast::FrameEvent>&)>;
 
 // RTP sender for a single Cast Remoting RTP stream. The client calls Send() to
 // instruct the sender to read from a Mojo data pipe and transmit the data using
@@ skipping 160 matching lines @@
   media::cast::RtpTimeTicks frame_rtp_timestamps_[256];
 
   // Queue of pending input operations. |input_queue_discards_remaining_|
   // indicates the number of operations where data should be discarded (due to
   // CancelInFlightData()).
   std::queue<base::Callback<bool(bool)>> input_queue_;
   size_t input_queue_discards_remaining_;
 
   // Watches |pipe_| for more data to become available, and then calls
   // ProcessInputQueue().
-  mojo::Watcher pipe_watcher_;
+  mojo::SimpleWatcher pipe_watcher_;
 
   // Set to true if the first frame has not yet been sent, or if a
   // CancelInFlightData() operation just completed. This causes TrySendFrame()
   // to mark the next frame as the start of a new sequence.
   bool flow_restart_pending_;
 
   // FrameEvents pending delivery via |frame_event_cb_|. No event is added if
   // |frame_event_cb_| is null.
   std::vector<media::cast::FrameEvent> recent_frame_events_;
 
   // NOTE: Weak pointers must be invalidated before all other member variables.
   base::WeakPtrFactory<CastRemotingSender> weak_factory_;
 
   DISALLOW_COPY_AND_ASSIGN(CastRemotingSender);
 };
 
 }  // namespace cast
 
 #endif  // CHROME_BROWSER_MEDIA_CAST_REMOTING_SENDER_H_