stream_puller.hh

#ifndef STREAM_PULLER_HH
#define STREAM_PULLER_HH

#include "media_capture/camera_capture.hh"
#include "utils/blocking_queue.hh"
#include <string>
#include <boost/thread.hpp>
#include <QObject>
#include "media_capture/frame.hh"
#include "header.hh"

class StreamPullerListener {
public:
  virtual void OnPullFrame(const std::string& user_id, MediaType media_type, std::shared_ptr<AVFRAME> frame) = 0;
};

class StreamPuller :
public QObject {
  Q_OBJECT
public:
  StreamPuller(const std::string& stream_id, const std::string& ip, int port, const std::string& user_id, MediaType media_type);
  ~StreamPuller();

  int CodecFrameFromServer();
  void RegisterListener(StreamPullerListener* listener);
  void UnRegisterListener(StreamPullerListener* listener);

private:
  std::string stream_id_;
  std::string ip_;
  int port_;
  std::string user_id_;
  MediaType media_type_;

  std::unique_ptr<boost::thread> codec_thread_;
  StreamPullerListener* listener_ = nullptr;
};

#endif // STREAM_PUSHER_HH