then() [1/2]

template<typename Executor , ComputeData DataType>

template<typename OpClass , ComputeData OutputType = DataType>

FluentExecutor< Executor, OutputType > MayaFlux::Yantra::FluentExecutor< Executor, DataType >::then ( )

inline

Chain an anonymous operation instance by type.

Constructs a new instance of OpClass and executes it on the current Datum. The full Datum (data + container + metadata) is passed through.

Template Parameters

OpClass	Operation class to instantiate and execute
OutputType	Expected output type (defaults to current DataType)

Returns

New FluentExecutor carrying the result Datum

Definition at line 128 of file OperationChain.hpp.

    {
        if (!m_successful) {
            error<std::runtime_error>(
                Journal::Component::Yantra, Journal::Context::ComputeMatrix,
                std::source_location::current(),
                "Cannot continue chain after failed operation");
        }
 
        try {
            auto result = m_executor->template execute<OpClass, DataType, OutputType>(m_data);
            if (!result) {
                m_successful = false;
                record_error("Operation " + std::string(typeid(OpClass).name()) + " failed");
                error<std::runtime_error>(
                    Journal::Component::Yantra, Journal::Context::ComputeMatrix,
                    std::source_location::current(),
                    "Operation failed in fluent chain: {}", std::string(typeid(OpClass).name()));
            }
 
            auto next = FluentExecutor<Executor, OutputType>(m_executor, std::move(*result));
            next.m_operation_history = m_operation_history;
            next.m_operation_history.push_back(typeid(OpClass).name());
            return next;
        } catch (const std::exception& e) {
            m_successful = false;
            record_error(e.what());
            error_rethrow(
                Journal::Component::Yantra, Journal::Context::ComputeMatrix,
                std::source_location::current(),
                "Exception in fluent chain: " + std::string(e.what()));
        }
    }