callbackimpl.h

Go to the documentation of this file.

 
#pragma once
 
#include <functional>
#include <utility>
 
template <typename TOwner, typename TCallbacks, typename TCallbackClientId>
template <typename TMemberFunction, typename... Arguments>
void CallbackManager<TOwner, TCallbacks, TCallbackClientId>::notify (TMemberFunction function, const Arguments &... arguments) {
    for (const auto &handler : registered_handlers) {
        if (handler.second.*function) {
            (handler.second.*function) (arguments...);
        }
    }
};
 
 
template <typename TOwner, typename TCallbacks, typename TCallbackClientId>
template <typename TMemberFunction, typename... Arguments>
void CallbackManager<TOwner, TCallbacks, TCallbackClientId>::callback (TMemberFunction function, Arguments &&... arguments) {
    for (const auto &handler : registered_handlers) {
        if (handler.second.*function) {
            (handler.second.*function) (std::forward<Arguments> (arguments)...);
        }
    }
};
 
template <typename TOwner, typename TCallbacks, typename TCallbackClientId>
template <typename TReturnType, typename TMemberFunction, typename... Arguments>
TReturnType CallbackManager<TOwner, TCallbacks, TCallbackClientId>::aggregate (TReturnType default_result,
                                                                               const std::function<TReturnType (TReturnType, TReturnType)> &combine,
                                                                               TMemberFunction function, const Arguments &... arguments) {
    for (auto handler = registered_handlers.begin(); handler != registered_handlers.end(); handler++) {
        if (handler->second.*function) {
            TReturnType computed_result = (handler->second.*function) (arguments...);
            while (++handler != registered_handlers.end()) {
                if (handler->second.*function) {
                    computed_result = combine ((handler->second.*function) (arguments...), computed_result);
                }
            }
            return computed_result;
        }
    }
    return default_result;
};
 
template <typename TOwner, typename TCallbacks, typename TCallbackClientId>
template <typename TMemberFunction, typename... Arguments>
inline bool CallbackManager<TOwner, TCallbacks, TCallbackClientId>::queryUnanimousApproval (bool default_result, TMemberFunction function, const Arguments &... arguments) {
    return aggregate (default_result, std::function<bool (bool, bool)> (std::logical_and <bool>()),
                      function, arguments...);
};
 
template <typename TOwner, typename TCallbacks, typename TCallbackClientId>
template <typename TMemberFunction, typename... Arguments>
inline bool CallbackManager<TOwner, TCallbacks, TCallbackClientId>::queryAnyApproval (bool default_result, TMemberFunction function, const Arguments &... arguments) {
    return aggregate (default_result, std::function<bool (bool, bool)> (std::logical_or <bool>()),
                      function, arguments...);
};
 
template <typename TOwner, typename TCallbacks, typename TCallbackClientId>
void CallbackManager<TOwner, TCallbacks, TCallbackClientId>::subscribe (const TCallbackClientId client_id, const TCallbacks &handlers) {
    registered_handlers [client_id] = handlers;
}
 
template <typename TOwner, typename TCallbacks, typename TCallbackClientId>
void CallbackManager<TOwner, TCallbacks, TCallbackClientId>::unsubscribe (const TCallbackClientId client_id) {
    registered_handlers.erase (client_id);
}