NewestFrameDataChannel.hpp

Go to the documentation of this file.

#pragma once
 
#include <FAST/DataChannels/DataChannel.hpp>
#include <queue>
 
namespace fast {
 
class FAST_EXPORT NewestFrameDataChannel : public DataChannel {
    FAST_OBJECT(NewestFrameDataChannel)
    public:
        virtual void addFrame(DataObject::pointer data) override;
 
        int getSize() override;
 
        void setMaximumNumberOfFrames(uint frames) override;
 
        void stop() override;
 
        // TODO consider removing, it is equal to getSize() > 0 atm
        bool hasCurrentData() override;
 
        DataObject::pointer getFrame() override;
    protected:
        std::condition_variable m_frameConditionVariable;
        std::shared_ptr<DataObject> m_frame;
 
        DataObject::pointer getNextDataFrame() override;
 
};
 
}