Class Decoding

MonaCore/include/Mona/Decoder.h:87–217

	virtual UInt32 decoding(Exception& ex, UInt8* data,UInt32 size) = 0;

	class Decoding : public WorkThread, private Task, public virtual Object,
		public Events::OnDecoding,
		public Events::OnDecoded<DecodedType>,
		public Events::OnDecodedEnd {
	public:

		class OutType : public virtual Object {
		public:
			template <typename ...Args>
			OutType(const PoolBuffers& poolBuffers,Args&&... args) : pBuffer(poolBuffers),decoded(args ...) {}

			DecodedType	decoded;
			PoolBuffer	pBuffer;
		};

		Decoding(Invoker& invoker, const char* name) : _pBuffer(invoker.poolBuffers), WorkThread(name), Task(invoker) {}

		virtual ~Decoding() {
			for (OutType* pOut : _output)
				delete pOut;
		}

		template <typename ...Args>
		void receive(Args&&... args) {
			_new = true;
			_pLastOut = new OutType(_pBuffer.poolBuffers,args ...);
			std::lock_guard<std::mutex> lock(_outMutex);
			_output.emplace_back(_pLastOut);
			_outAddresses.emplace_back(_address);
		}

		bool run(Exception& ex) {

			// Just one!

			_new = false;

			PoolBuffer pBuffer(_pBuffer.poolBuffers);
			{
				std::lock_guard<std::mutex> lock(_inMutex);
				ASSERT_RETURN(!_input.empty(),true)
				pBuffer.swap(_input.front());
				_input.pop_front();
				_address = _inAddresses.front();
				_inAddresses.pop_front();
			}

			// add general buffer in front
			if (!_pBuffer.empty()) {
				if (!pBuffer.empty())
					_pBuffer->append(pBuffer.data(),pBuffer.size());
				pBuffer.swap(_pBuffer);
				_pBuffer.release();
			}

			UInt32 consumed(0);
			
			while(consumed<pBuffer.size()) { // while everything is not consumed