PeersProcessor.h

Go to the documentation of this file.

 
#pragma once
#include "catapult/ionet/Node.h"
#include "catapult/net/NodeRequestResult.h"
#include "catapult/functions.h"
 
namespace catapult { namespace ionet { class NodeContainer; } }
 
namespace catapult { namespace nodediscovery {
 
    class PeersProcessor {
    private:
        using NodeConsumer = consumer<const ionet::Node&>;
        using NodePingRequestInitiator = consumer<const ionet::Node&, const consumer<net::NodeRequestResult, const ionet::Node&>&>;
 
    public:
        PeersProcessor(
                const ionet::NodeContainer& nodeContainer,
                const NodePingRequestInitiator& pingRequestInitiator,
                model::NetworkIdentifier networkIdentifier,
                const NodeConsumer& newPartnerNodeConsumer);
 
    public:
        void process(const ionet::NodeSet& candidateNodes) const;
 
    private:
        void process(const ionet::Node& candidateNode) const;
 
    private:
        const ionet::NodeContainer& m_nodeContainer;
        NodePingRequestInitiator m_pingRequestInitiator;
        model::NetworkIdentifier m_networkIdentifier;
        NodeConsumer m_newPartnerNodeConsumer;
    };
}}