Function-type templated CallbackRegistry

base/callback_registry.h.pump

+$$ This is a pump file for generating file templates.  Pump is a python
+$$ script that is part of the Google Test suite of utilities.  Description
+$$ can be found here:
+$$
+$$ http://code.google.com/p/googletest/wiki/PumpManual
+$$
+
+$$ See comment for MAX_ARITY in base/bind.h.pump.
+$var MAX_ARITY = 7
+
 // Copyright 2013 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 BASE_CALLBACK_REGISTRY_H_
 #define BASE_CALLBACK_REGISTRY_H_
 
 #include <list>
 
 #include "base/basictypes.h"
 #include "base/callback.h"
+#include "base/callback_internal.h"
 #include "base/compiler_specific.h"
 #include "base/logging.h"
 #include "base/memory/scoped_ptr.h"
 
 // OVERVIEW:
 //
 // A container for a list of callbacks.  Unlike a normal STL vector or list,
 // this container can be modified during iteration without invalidating the
 // iterator. It safely handles the case of a callback removing itself
 // or another callback from the list while callbacks are being run.
 //
 // TYPICAL USAGE:
 //
 // class MyWidget {
 //  public:
 //   ...
 //
 //   typedef base::Callback<void(const Foo&)> OnFooCallback;
 //
-//   scoped_ptr<base::CallbackRegistry<Foo>::Subscription> RegisterCallback(
-//       const OnFooCallback& cb) {
+//   scoped_ptr<base::CallbackRegistry<void(const Foo&)>::Subscription>
+//   RegisterCallback(const OnFooCallback& cb) {
 //     return callback_registry_.Add(cb);
 //   }
 //
 //  private:
 //   void NotifyFoo(const Foo& foo) {
 //      callback_registry_.Notify(foo);
 //   }
 //
-//   base::CallbackRegistry<Foo> callback_registry_;
+//   base::CallbackRegistry<void(const Foo&)> callback_registry_;
 // };
 //
 //
 // class MyWidgetListener {
 //  public:
 //   MyWidgetListener::MyWidgetListener() {
 //     foo_subscription_ = MyWidget::GetCurrent()->RegisterCallback(
 //             base::Bind(&MyWidgetListener::OnFoo, this)));
 //   }
 //
@@ skipping 114 matching lines @@
 
  private:
   std::list<CallbackType> callbacks_;
   int active_iterator_count_;
 
   DISALLOW_COPY_AND_ASSIGN(CallbackRegistryBase);
 };
 
 }  // namespace internal
 
-template <typename Details>
-class CallbackRegistry
-    : public internal::CallbackRegistryBase<Callback<void(const Details&)> > {
+template <typename Sig> class CallbackRegistry;
+
+
+$range ARITY 0..MAX_ARITY
+$for ARITY [[
+$range ARG 1..ARITY
+
+$if ARITY == 0 [[
+template <>
+class CallbackRegistry<void(void)>
+    : public internal::CallbackRegistryBase<Callback<void(void)> > {
+]] $else [[
+template <$for ARG , [[typename A$(ARG)]]>
+class CallbackRegistry<void($for ARG , [[A$(ARG)]])>
+    : public internal::CallbackRegistryBase<
+          Callback<void($for ARG , [[A$(ARG)]])> > {
+]]
+
  public:
+$if ARITY == 0 [[
+
+  typedef Callback<void(void)> CallbackType;
+]] $else [[
+
+  typedef Callback<void($for ARG , [[A$(ARG)]])> CallbackType;
+]]
+
+
   CallbackRegistry() {}
 
-  // Execute all active callbacks with |details| parameter.
-  void Notify(const Details& details) {
-    typename internal::CallbackRegistryBase<
-        Callback<void(const Details&)> >::Iterator it = this->GetIterator();
-    Callback<void(const Details&)>* cb;
+  void Notify($for ARG ,
+              [[typename internal::CallbackParamTraits<A$(ARG)>::ForwardType a$(ARG)]]) {
+$if ARITY == 0 [[
+
+    internal::CallbackRegistryBase<CallbackType>::Iterator it =
+        this->GetIterator();
+]] $else [[
+
+    typename internal::CallbackRegistryBase<CallbackType>::Iterator it =
+        this->GetIterator();
+]]
+
+    CallbackType* cb;
     while((cb = it.GetNext()) != NULL) {
-      cb->Run(details);
+      cb->Run($for ARG , [[a$(ARG)]]);
     }
   }
 
-private:
-  DISALLOW_COPY_AND_ASSIGN(CallbackRegistry);
-};
-
-template <> class CallbackRegistry<void>
-    : public internal::CallbackRegistryBase<Closure> {
- public:
-  CallbackRegistry() {}
-
-  // Execute all active callbacks.
-  void Notify() {
-    Iterator it = this->GetIterator();
-    Closure* cb;
-    while((cb = it.GetNext()) != NULL) {
-      cb->Run();
-    }
-  }
-
  private:
   DISALLOW_COPY_AND_ASSIGN(CallbackRegistry);
 };
 
+
+]]  $$ for ARITY
 }  // namespace base
 
-#endif  // BASE_CALLBACK_REGISTRY_H_
+#endif  // BASE_CALLBACK_REGISTRY_H