PipelineSynchronizer.hpp

Go to the documentation of this file.

#pragma once
 
#include <FAST/ProcessObject.hpp>
 
namespace fast {
 
class FAST_EXPORT PipelineSynchronizer : public ProcessObject {
    FAST_OBJECT(PipelineSynchronizer)
    public:
        virtual uint addInputConnection(DataChannel::pointer port);
    protected:
        void execute() override;
 
        std::unordered_map<uint, std::shared_ptr<DataObject>> m_latestData;
};
 
}