MediaAov.hpp

//
// Created by tfh on 2024/09/02.
//
 
#ifndef EMX_MediaAov_HPP
#define EMX_MediaAov_HPP
 
#include "media/common/MediaInfAov.hpp"
#include "MediaParamCBase.hpp"
#include "EmxCore.hpp"
 
namespace Emx {
    class MediaAov : public MediaInfAov, public MediaParamCBase<MediaInfAov::Param> {
    public:
        explicit MediaAov(int32_t chn) : MediaParamCBase(MediaModE::Aov, chn) {}
 
        ErrCodeE UpdateStatus(AovStatusTypeE type) override;
    };
    class MediaAovMessage {
    public:
        MediaAovMessage() : m_started(false) {}
 
        using OnGetInfoCallback = std::function<void(MediaInfAov::AovPushFrame &frame)>;
 
        ErrCodeE Start(EuvLoop &loop, char *buffer, int bufferSize, OnGetInfoCallback cb);
 
        void Stop();
 
    protected:
        void OnMsgRecv(uint32_t topic, const char *data, int32_t size);
 
    private:
        MsgTopicSubscriberAsync m_sub;
        OnGetInfoCallback m_cb;
        bool m_started;
    };
}// namespace Emx
 
#endif//EMX_MediaAov_HPP