MultiResultStep.h

Go to the documentation of this file.

// Copyright (C) 2022 ASTRON (Netherlands Institute for Radio Astronomy)
// SPDX-License-Identifier: GPL-3.0-or-later
 
#ifndef DP3_STEPS_MULTIRESULTSTEP_H_
#define DP3_STEPS_MULTIRESULTSTEP_H_
 
#include "Step.h"
 
namespace dp3 {
namespace steps {
 
class MultiResultStep : public Step {
 public:
  explicit MultiResultStep(unsigned int size);
 
  ~MultiResultStep() override {}
 
  common::Fields getRequiredFields() const override { return {}; }
 
  common::Fields getProvidedFields() const override { return {}; }
 
  bool process(std::unique_ptr<base::DPBuffer> buffer) override;
 
  void finish() override { getNextStep()->finish(); }
 
  void show(std::ostream&) const override{};
 
  const std::vector<std::unique_ptr<base::DPBuffer>>& get() const {
    return buffers_;
  }
  std::vector<std::unique_ptr<base::DPBuffer>>& get() { return buffers_; }
 
  size_t size() const { return size_; }
 
  void clear() { size_ = 0; }
 
 private:
  std::vector<std::unique_ptr<base::DPBuffer>> buffers_;
  size_t size_;
};
 
}  // namespace steps
}  // namespace dp3
 
#endif