#pragma once
#include "CReadStep.h"
#include <functional>


#define READ_BUFFER_MAX		2048

#define ROK				0					/* ¶ÁÊý¾ÝOK */
#define RTIMEOUT		-1					/* ¶ÁÊý¾Ý³¬Ê± */
#define RERROR			-2					/* ¶ÁÊý¾Ý³ö´í */
#define RCOMPLETE		1					/* ¶ÁÊý¾ÝÁ÷³ÌÍê³É */

namespace SERVO {
	typedef std::function<int(void* pFrom, int code, const char* pszData, size_t size)> ONREAD;

	class CEqReadStep : public CReadStep
	{
	public:
		CEqReadStep();
		CEqReadStep(int dev, size_t readSize, ONREAD onReadBlock);
		virtual ~CEqReadStep();

	public:
		virtual void getAttributeVector(CAttributeVector& attrubutes);
		virtual int onReadData();
		virtual int onComplete();
		virtual int onTimeout();

	private:
		ONREAD m_onReadBlock;
		int m_nDataDev;
		size_t m_nReadSize;
	};
}