BatchPeersRequestor.h

Go to the documentation of this file.

 
#pragma once
#include "catapult/ionet/Node.h"
#include "catapult/ionet/NodeInteractionResult.h"
#include "catapult/net/PacketIoPickerContainer.h"
#include "catapult/thread/Future.h"
 
namespace catapult { namespace nodediscovery {
 
    class BatchPeersRequestor {
    private:
        using NodesConsumer = consumer<const ionet::NodeSet&>;
        using RemoteApiResults = std::vector<ionet::NodeInteractionResult>;
 
    public:
        explicit BatchPeersRequestor(const net::PacketIoPickerContainer& packetIoPickers, const NodesConsumer& nodesConsumer);
 
    public:
        thread::future<RemoteApiResults> findPeersOfPeers(const utils::TimeSpan& timeout) const;
 
    private:
        net::PacketIoPickerContainer m_packetIoPickers; // held by value because packet io pickers is tied to ServiceState
        NodesConsumer m_nodesConsumer;
    };
}}