DataConverterBase.hpp

Go to the documentation of this file.

#pragma once
 
#include <boost/asio/experimental/coro.hpp>
#include <fmt/ranges.h>
 
#include <srs/utils/CommonFunctions.hpp>
#include <srs/writers/DataWriter.hpp>
 
namespace srs::process
{
    template <typename Input, typename Output>
    class DataConverterBase
    {
      public:
        using InputType = Input;
        using OutputType = Output;
        using InputFuture = boost::shared_future<std::optional<InputType>>;
        using OutputFuture = boost::shared_future<std::optional<OutputType>>;
        using CoroType = asio::experimental::coro<OutputType(std::optional<InputType>)>;
 
        using enum DataConvertOptions;
 
        explicit DataConverterBase(auto coro)
            : coro_(std::move(coro))
        {
            common::coro_sync_start(coro_, std::optional<InputType>{}, asio::use_awaitable);
        }
 
        auto create_future(this auto&& self, InputFuture& pre_fut, writer::Manager& writers) -> OutputFuture
        {
            constexpr auto converter_options = std::remove_cvref_t<decltype(self)>::ConverterOption;
            auto is_needed = std::ranges::any_of(
                converter_options, [&writers](auto option) { return writers.is_convert_required(option); });
            return is_needed ? common::create_coro_future(self.coro_, pre_fut) : OutputFuture{};
        }
 
      private:
        CoroType coro_;
    };
} // namespace srs