[mojo-bindings] Use Watcher API for JS bindings

mojo/edk/js/waiting_callback.h

Index: mojo/edk/js/waiting_callback.h
diff --git a/mojo/edk/js/waiting_callback.h b/mojo/edk/js/waiting_callback.h
index f2554bc293ac3b7e360c97d0d5834d9b7421ecea..d11391518c81111286946af4b7cf2f3a0c0637d5 100644
--- a/mojo/edk/js/waiting_callback.h
+++ b/mojo/edk/js/waiting_callback.h
@@ -12,24 +12,28 @@
 #include "gin/wrappable.h"
 #include "mojo/edk/js/handle.h"
 #include "mojo/edk/js/handle_close_observer.h"

[yzshen1, 2016/03/08 23:02:42]

nit: This is not needed anymore.

-#include "mojo/message_pump/handle_watcher.h"
 #include "mojo/public/cpp/system/core.h"
+#include "mojo/public/cpp/system/watcher.h"
 
 namespace mojo {
 namespace edk {
 namespace js {
 
-class WaitingCallback : public gin::Wrappable<WaitingCallback>,
-                        public HandleCloseObserver {
+class WaitingCallback : public gin::Wrappable<WaitingCallback> {
  public:
   static gin::WrapperInfo kWrapperInfo;
 
   // Creates a new WaitingCallback.
+  //
+  // If |one_shot| is true, the callback will only ever be called at most once.
+  // If false, the callback may be called any number of times until the
+  // WaitingCallback is explicitly cancelled.
   static gin::Handle<WaitingCallback> Create(
       v8::Isolate* isolate,
       v8::Handle<v8::Function> callback,
       gin::Handle<HandleWrapper> handle_wrapper,
-      MojoHandleSignals signals);
+      MojoHandleSignals signals,
+      bool one_shot);
 
   // Cancels the callback. Does nothing if a callback is not pending. This is
   // implicitly invoked from the destructor but can be explicitly invoked as
@@ -39,24 +43,21 @@ class WaitingCallback : public gin::Wrappable<WaitingCallback>,
  private:
   WaitingCallback(v8::Isolate* isolate,
                   v8::Handle<v8::Function> callback,
-                  gin::Handle<HandleWrapper> handle_wrapper);
+                  bool one_shot);
   ~WaitingCallback() override;
 
-  // Callback from common::HandleWatcher.
+  // Callback from the Watcher.
   void OnHandleReady(MojoResult result);
 
-  // Invoked by the HandleWrapper if the handle is closed while this wait is
-  // still in progress.
-  void OnWillCloseHandle() override;
-
-  void RemoveHandleCloseObserver();
   void CallCallback(MojoResult result);
 
-  base::WeakPtr<gin::Runner> runner_;
-
-  common::HandleWatcher handle_watcher_;
+  // Indicates whether this is a one-shot callback or not. If so, it uses the
+  // deprecated HandleWatcher to wait for signals; otherwise it uses the new
+  // system Watcher API.
+  const bool one_shot_;
 
-  HandleWrapper* handle_wrapper_;
+  base::WeakPtr<gin::Runner> runner_;
+  Watcher watcher_;
   base::WeakPtrFactory<WaitingCallback> weak_factory_;
 
   DISALLOW_COPY_AND_ASSIGN(WaitingCallback);