stream.hpp

/*
 * See LICENSE for more information about licensing
 *
 * Copyright 2024
 * Author: Luis G. Leon-Vega <luis.leon@ieee.org>
 *
 */
#pragma once
#include <cynq/enums.hpp>
#include <cynq/execution-graph.hpp>
#include <cynq/status.hpp>
#include <memory>
#include <vector>
 
namespace cynq {
class ExecutionStream : public IExecutionGraph {
 public:
  explicit ExecutionStream(std::shared_ptr<ExecutionGraphParameters> params);
 
  NodeID Add(const IExecutionGraph::Function &function,
             const std::vector<IExecutionGraph::NodeID> dependencies =
                 std::vector<IExecutionGraph::NodeID>(0)) override;
 
  Status Sync(const IExecutionGraph::NodeID node = -1) override;
 
  Status GetLastError() override;
 
  virtual ~ExecutionStream();
 
 private:
  std::shared_ptr<ExecutionGraphParameters> params_;
 
  void Worker();
};
}  // namespace cynq