#pragma once


#include <functional>


class NetBuffer;
class BUSNetSend;
class BUSNetSendStream;


#ifndef _ServiceBus_DLL
#define _ServiceBus_API	_declspec(dllimport)
#else
#define _ServiceBus_API	_declspec(dllexport)
#endif


namespace ECOM
{
namespace ServiceBus
{
namespace Controller
{
	//-----------------------------------------------------------------------------
	//		BUSStream
	//-----------------------------------------------------------------------------

	class _ServiceBus_API BUSStream
	{
	private:
		NetBuffer * m_NetBuffer;

	public:
		BUSStream (BUSStream && stream);
		BUSStream (const BUSStream & stream);

	private:
		BUSStream (NetBuffer * buf);

	public:
		void Write (const void * pData, int length);

	private:
		bool Send (NetBuffer * PDU, const void * pData, int length);

		friend BUSNetSendStream;
	};

}
}
};


typedef  std::function <void (ECOM::ServiceBus::Controller::BUSStream)>  funstream;