data_reader.hpp

#pragma once
#include <atomic>
#include <optional>
#include <thread>
 
#include <spdlog/spdlog.h>
#include <zmq.hpp>
 
namespace synapse {

class ZMQDataReader {
 public:
  explicit ZMQDataReader(zmq::context_t& context);

  ~ZMQDataReader();

  bool connect(const std::string& publisher_endpoint);

  std::optional<zmq::message_t> receive_message();

  std::vector<zmq::message_t> receive_multipart();
 
 private:
  zmq::context_t& zmq_context_;

  std::atomic<bool> connected_{false};

  zmq::socket_t subscriber_socket_;

  std::string publisher_endpoint_;

  void subscriber_close();

  void stop();
};
}  // namespace synapse