RemoteNodeSynchronizer.h

Go to the documentation of this file.

 
#pragma once
#include "catapult/ionet/NodeInteractionResultCode.h"
#include "catapult/thread/FutureUtils.h"
#include <functional>
 
namespace catapult { namespace chain {
 
    template<typename TRemoteApi>
    using RemoteNodeSynchronizer = std::function<thread::future<ionet::NodeInteractionResultCode> (const TRemoteApi&)>;
 
    template<typename TSynchronizer>
    RemoteNodeSynchronizer<typename TSynchronizer::RemoteApiType> CreateRemoteNodeSynchronizer(
            const std::shared_ptr<TSynchronizer>& pSynchronizer) {
        return [pSynchronizer](const auto& remoteApi) {
            // pSynchronizer is captured in the second lambda to compose, which extends its lifetime until
            // the async operation is complete
            return thread::compose(pSynchronizer->operator()(remoteApi), [pSynchronizer](auto&& future) {
                return std::move(future);
            });
        };
    }
}}