[mojo-edk] Expose notification source to MojoWatch callbacks

mojo/public/cpp/bindings/tests/binding_unittest.cc

 // Copyright 2015 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.
 
 // Note: This file tests both binding.h (mojo::Binding) and strong_binding.h
 // (mojo::StrongBinding).
 
 #include "mojo/public/cpp/bindings/binding.h"
 
 #include <stdint.h>
@@ skipping 293 matching lines @@
   loop().RunUntilIdle();
   // The connection error handle should not be called as the binding is paused.
   EXPECT_FALSE(called);
 
   // Resume the binding, which should trigger the error handler.
   binding.ResumeIncomingMethodCallProcessing();
   run_loop.Run();
   EXPECT_TRUE(called);
 }
 
+class SingleMethodImpl : public sample::SingleMethod {
+ public:
+  explicit SingleMethodImpl(const Closure& on_call) : on_call_(on_call) {}
+  ~SingleMethodImpl() override {}
+
+ private:
+  // sample::SingleMethod:
+  void Call() override { on_call_.Run(); }
+
+  const Closure on_call_;
+};
+
+// Tests that sync dispatch works when enabled on a Binding.
+TEST_F(BindingTest, SyncDispatch) {
+  bool called = false;
+  sample::SingleMethodPtr ptr;
+  SingleMethodImpl impl([&called] { called = true; });
+  Binding<sample::SingleMethod> binding(&impl, GetProxy(&ptr));
+  binding.EnableImmediateDispatchOfEventsFromSameThread(true);
+  ptr->Call();
+  EXPECT_TRUE(called);
+}
+
 // StrongBindingTest -----------------------------------------------------------
 
 using StrongBindingTest = BindingTestBase;
 
 // Tests that destroying a mojo::StrongBinding closes the bound message pipe
 // handle but does *not* destroy the implementation object.
 TEST_F(StrongBindingTest, DestroyClosesMessagePipe) {
   base::RunLoop run_loop;
   bool encountered_error = false;
   bool was_deleted = false;
@@ skipping 93 matching lines @@
   was_deleted = false;  // It shouldn't be double-deleted!
   run_loop.Run();
   EXPECT_TRUE(ptr_error_handler_called);
   EXPECT_FALSE(was_deleted);
 
   EXPECT_FALSE(binding_error_handler_called);
 }
 
 }  // namespace
 }  // mojo