rxcore.hpp

Go to the documentation of this file.

 
#pragma once
 
#include <cstdint>
#include <vector>
#include <chrono>
#include <set>
#include <functional>
 
 
#include "itk/types.hpp"
#include "itk/logger.hpp"
 
namespace hwc {
 
class RxCore {
public:
 
  virtual ~RxCore() = default;
 
  virtual void init_subscribe(netio_tag_t fid) = 0;
 
  virtual void subscribe(netio_tag_t fid) = 0;
 
  virtual void subscribe(const std::vector<netio_tag_t>& fids) = 0;
 
  virtual void unsubscribe(netio_tag_t fid) = 0;
 
  virtual void unsubscribe_all() = 0;
 
  typedef std::function<void(netio_tag_t fid, const uint8_t* data, size_t size)> OnDataCallback;
 
  virtual void callback_on_data(OnDataCallback on_data) = 0;
 
  virtual std::string get_fe_type() = 0;
 
}; // RxCore
 
} // hwc