i420_video_renderer.hpp

#ifndef SKYWAY_MEDIA_I420_VIDEO_RENDERER_HPP_
#define SKYWAY_MEDIA_I420_VIDEO_RENDERER_HPP_
 
#include <mutex>
#include <optional>
 
#include "skyway/media/interface/i420_video_renderer.hpp"
 
namespace skyway {
namespace media {
class I420VideoRenderer : public interface::I420VideoRenderer {
public:
    I420VideoRenderer(const interface::I420VideoRendererOptions& options);
    ~I420VideoRenderer();
 
    void RegisterListener(interface::I420VideoRenderer::Listener* listener) override;
 
    void UnregisterListener(interface::I420VideoRenderer::Listener* listener) override;
 
    void Render(std::shared_ptr<stream::interface::remote::RemoteVideoStream> stream) override;
 
    // rtc::VideoSinkInterface<webrtc::VideoFrame>
    void OnFrame(const webrtc::VideoFrame& frame) override;
 
protected:
    std::optional<interface::I420Frame> ConvertI420Frame(const webrtc::VideoFrame& frame);
    void DetachSink();
 
private:
    rtc::scoped_refptr<webrtc::MediaStreamTrackInterface> track_;
    std::mutex track_mtx_;
    std::mutex rendering_mtx_;
    const interface::I420VideoRendererOptions options_;
    std::unordered_set<Listener*> listeners_;
};
 
}  // namespace media
}  // namespace skyway
 
#endif /* SKYWAY_MEDIA_I420_VIDEO_RENDERER_HPP_ */