pipeline.h

#ifndef INCLUDE_GAZE_PIPELINE_H_
#define INCLUDE_GAZE_PIPELINE_H_

#include <atomic>
#include <shared_mutex>  // NOLINT
#include <thread>  // NOLINT
#include <vector>

#include "gaze/pipeline_step.h"
#include "gaze/util/data.h"


namespace gaze {

class Pipeline {
  std::atomic<bool> debug = std::atomic<bool>(false);
  std::atomic<bool> running = std::atomic<bool>(false);
  std::shared_mutex data_access_mutex;
  util::Data current_data;
  std::vector<PipelineStep*> steps;
  std::thread* thread;

  void operator()();

 public:
    //{@
    explicit Pipeline(std::vector<PipelineStep*> steps,
                      const bool start = true);

    ~Pipeline();

    //{@
    void start();

    void stop();


    util::Data get_data();

    std::vector<PipelineStep*> get_steps();
};

}  // namespace gaze

#endif  // INCLUDE_GAZE_PIPELINE_H_