Add FlushForTesting to InterfacePtr and Binding.

mojo/public/cpp/bindings/binding_set.h

 // 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.
 
 #ifndef MOJO_PUBLIC_CPP_BINDINGS_BINDING_SET_H_
 #define MOJO_PUBLIC_CPP_BINDINGS_BINDING_SET_H_
 
 #include <utility>
 
 #include "base/bind.h"
@@ skipping 77 matching lines @@
   // context associated with the specific binding which received the message or
   // error. Use AddBinding() to associated a context with a specific binding.
   //
   // Note that this may ONLY be called if the BindingSet was constructed with
   // |BindingSetDispatchMode::WITH_CONTEXT|.
   void* dispatch_context() const {
     DCHECK(SupportsContext());
     return dispatch_context_;
   }
 
+  void FlushForTesting() {
+    for (auto& binding : bindings_) {
+      binding.first->FlushForTesting();
+    }
+  }
+
  private:
   friend class Entry;
 
   class Entry {
    public:
     Entry(Interface* impl,
           RequestType request,
           BindingSet* binding_set,
           void* context)
         : binding_(impl, std::move(request)),
           binding_set_(binding_set),
           context_(context) {
       if (binding_set->SupportsContext())
         binding_.AddFilter(base::MakeUnique<DispatchFilter>(this));
       binding_.set_connection_error_handler(base::Bind(
           &Entry::OnConnectionError, base::Unretained(this)));
     }
 
+    void FlushForTesting() { binding_.FlushForTesting(); }
+
    private:
     class DispatchFilter : public MessageReceiver {
      public:
       explicit DispatchFilter(Entry* entry) : entry_(entry) {}
       ~DispatchFilter() override {}
 
      private:
       // MessageReceiver:
       bool Accept(Message* message) override {
         entry_->WillDispatch();
@@ skipping 45 matching lines @@
   base::Closure error_handler_;
   std::map<Entry*, std::unique_ptr<Entry>> bindings_;
   void* dispatch_context_ = nullptr;
 
   DISALLOW_COPY_AND_ASSIGN(BindingSet);
 };
 
 }  // namespace mojo
 
 #endif  // MOJO_PUBLIC_CPP_BINDINGS_BINDING_SET_H_