ServiceUtils.h

Go to the documentation of this file.

 
#pragma once
#include "ServiceLocator.h"
#include "catapult/ionet/BroadcastUtils.h"
#include "catapult/net/PacketWriters.h"
#include <string>
 
namespace catapult { namespace extensions {
 
    template<typename TSink>
    TSink CreatePushEntitySink(const extensions::ServiceLocator& locator, const std::string& serviceName) {
        return [&locator, serviceName](const auto& entities) {
            auto payload = ionet::CreateBroadcastPayload(entities);
            locator.service<net::PacketWriters>(serviceName)->broadcast(payload);
        };
    }
 
    template<typename TSink>
    TSink CreatePushEntitySink(const extensions::ServiceLocator& locator, const std::string& serviceName, ionet::PacketType packetType) {
        return [&locator, serviceName, packetType](const auto& entities) {
            auto payload = ionet::CreateBroadcastPayload(entities, packetType);
            locator.service<net::PacketWriters>(serviceName)->broadcast(payload);
        };
    }
}}