HeadCountAlgo/strategy/stradef/include/StraStreamPipe.h

#ifndef __MAS_STEA_STREAMPIPE_H
#define __MAS_STEA_STREAMPIPE_H

#include "StrategyLib.h"

#include "StreamDef.h"

NAMESPACE_MAS_BEGIN

class StraStreamPipe : public IStreamPipe {

public:
	StraStreamPipe(TZ_INT sceneID, 
		const std::string & sceneName, TZ_INT straId, 
		const std::string & straParams, const ExcepInfo & einfo);
	virtual ~StraStreamPipe();

	virtual TZ_INT Initialize(SPtr<StrategyLib> & straLib);
	virtual TZ_INT Dispose();

	TZ_INT SetStrategyCfg(const std::string & param);

protected:
    virtual std::tuple<TZ_BOOL, TZ_BOOL> streamArrived(
        SPtr<StreamInfo> & streamInfo) override;

private:
	void addRecord(SPtr<StraProducing> & producing);

private:
	class Strategy * 	m_strategy;
	SPtr<StrategyLib> 	m_straLib;

	std::string 		m_straKey;
	std::string 		m_sceneName;
	std::string 		m_straParams;
};

NAMESPACE_MAS_END

#endif