AggregateNodeSubscriber.h

Go to the documentation of this file.

 
#pragma once
#include "BasicAggregateSubscriber.h"
#include "NodeSubscriber.h"
 
namespace catapult { namespace subscribers {
 
    template<typename TNodeSubscriber = NodeSubscriber>
    class AggregateNodeSubscriber : public BasicAggregateSubscriber<TNodeSubscriber>, public NodeSubscriber {
    public:
        using BasicAggregateSubscriber<TNodeSubscriber>::BasicAggregateSubscriber;
 
    public:
        void notifyNode(const ionet::Node& node) override {
            this->forEach([&node](auto& subscriber) { subscriber.notifyNode(node); });
        }
 
        void notifyIncomingNode(const Key& identityKey, ionet::ServiceIdentifier serviceId) override {
            this->forEach([&identityKey, serviceId](auto& subscriber) { subscriber.notifyIncomingNode(identityKey, serviceId); });
        }
    };
}}