reactor.hpp

 
#pragma once
 
#include "../asrtl/asrt_assert.h"
#include "../asrtl/log.h"
#include "../asrtl/status_to_str.h"
#include "../asrtlpp/util.hpp"
#include "../asrtr/reactor.h"
 
#include <span>
 
namespace asrt
{
 
using send_req_list = asrt_send_req_list;
using record        = asrt_record;
 
template < typename T >
struct unit : asrt_test
{
        template < typename... Args >
        unit( Args&&... args )
          : test( (Args&&) args... )
        {
                asrt_test_init( this, test.name(), static_cast< unit* >( this ), unit::cb );
        }
 
        unit( unit&& )      = delete;
        unit( unit const& ) = delete;
 
        static asrt_status cb( record* rec )
        {
                auto*       self = static_cast< unit* >( rec->inpt->test_ptr );
                asrt_status st   = self->test( *rec );
                if ( st != ASRT_SUCCESS )
                        rec->state = ASRT_TEST_FAIL;
                return st;
        }
 
        T test;
};
 
ASRT_NODISCARD inline enum asrt_status init(
    ref< asrt_reactor > reac,
    send_req_list&      req_l,
    char const*         desc )
{
        return asrt_reactor_init( reac, &req_l, desc );
}
ASRT_NODISCARD inline enum asrt_status add_test( ref< asrt_reactor > reac, asrt_test& test )
{
        return asrt_reactor_add_test( reac, &test );
}
 
inline void deinit( ref< asrt_reactor > reac )
{
        asrt_reactor_deinit( reac );
}
 
}  // namespace asrt