stream.hpp

 
#pragma once
 
#include "../asrtc/stream.h"
#include "../asrtl/asrt_assert.h"
#include "../asrtl/log.h"
#include "../asrtl/status_to_str.h"
#include "../asrtlpp/util.hpp"
 
namespace asrt
{
 
using status = asrt_status;
 
struct stream_schemas
{
        stream_schemas() = default;
 
        explicit stream_schemas( asrt_stream_schemas s )
          : _s( s )
        {
        }
 
        stream_schemas( stream_schemas const& )            = delete;
        stream_schemas& operator=( stream_schemas const& ) = delete;
 
        stream_schemas( stream_schemas&& o ) noexcept
          : _s( o._s )
        {
                o._s = {};
        }
 
        stream_schemas& operator=( stream_schemas&& o ) noexcept;
 
        ~stream_schemas();
 
        asrt_stream_schemas const* operator->() const { return &_s; }
 
        asrt_stream_schemas const& operator*() const { return _s; }
 
private:
        asrt_stream_schemas _s{};
};
 
ASRT_NODISCARD inline status init(
    ref< asrt_stream_server > srv,
    asrt_node&                prev,
    asrt_allocator            alloc )
{
        return asrt_stream_server_init( srv, &prev, alloc );
}
 
ASRT_NODISCARD inline stream_schemas take( ref< asrt_stream_server > srv )
{
        return stream_schemas{ asrt_stream_server_take( srv ) };
}
 
inline void clear( ref< asrt_stream_server > srv )
{
        asrt_stream_server_clear( srv );
}
 
inline void deinit( ref< asrt_stream_server > srv )
{
        asrt_stream_server_deinit( srv );
}
 
}  // namespace asrt