pipeline.hxx

#pragma once
 
#include <StormByte/buffer/consumer.hxx>
#include <StormByte/buffer/producer.hxx>
#include <StormByte/buffer/typedefs.hxx>
 
namespace StormByte::Buffer {
    class STORMBYTE_PUBLIC Pipeline final {
        public:
            Pipeline() noexcept                                             = default;
 
            Pipeline(const Pipeline& other)                                 = default;
 
            Pipeline(Pipeline&& other) noexcept                             = default;
 
            ~Pipeline() noexcept                                            = default;
 
            Pipeline& operator=(const Pipeline& other)                      = default;
 
            Pipeline& operator=(Pipeline&& other) noexcept                  = default;
 
            void                                                            AddPipe(const PipeFunction& pipe);
 
            void                                                            AddPipe(PipeFunction&& pipe);
 
            Consumer                                                        Process(Consumer buffer) const noexcept;
 
        private:
            std::vector<PipeFunction> m_pipes;                              
    };
}