AggregateStateChangeSubscriber.h

Go to the documentation of this file.

 
#pragma once
#include "BasicAggregateSubscriber.h"
#include "StateChangeSubscriber.h"
 
namespace catapult { namespace subscribers {
 
    template<typename TStateChangeSubscriber = StateChangeSubscriber>
    class AggregateStateChangeSubscriber : public BasicAggregateSubscriber<TStateChangeSubscriber>, public StateChangeSubscriber {
    public:
        using BasicAggregateSubscriber<TStateChangeSubscriber>::BasicAggregateSubscriber;
 
    public:
        void notifyScoreChange(const model::ChainScore& chainScore) override {
            this->forEach([&chainScore](auto& subscriber) { subscriber.notifyScoreChange(chainScore); });
        }
 
        void notifyStateChange(const StateChangeInfo& stateChangeInfo) override {
            this->forEach([&stateChangeInfo](auto& subscriber) { subscriber.notifyStateChange(stateChangeInfo); });
        }
    };
}}