Method Get

libi2pd/Streaming.cpp:31–72

	}

	size_t SendBufferQueue::Get (uint8_t * buf, size_t len)
	{
		if (!m_Size) return 0;
		size_t offset = 0;
		if (len >= m_Size)
		{
			for (auto& it: m_Buffers)
			{
				auto rem = it->GetRemainingSize ();
				memcpy (buf + offset, it->GetRemaningBuffer (), rem);
				offset += rem;
			}
			m_Buffers.clear ();
			m_Size = 0;
			return offset;
		}
		else
		{
			while (!m_Buffers.empty () && offset < len)
			{
				auto nextBuffer = m_Buffers.front ();
				auto rem = nextBuffer->GetRemainingSize ();
				if (offset + rem <= len)
				{
					// whole buffer
					memcpy (buf + offset, nextBuffer->GetRemaningBuffer (), rem);
					offset += rem;
					m_Buffers.pop_front (); // delete it
				}
				else
				{
					// partially
					rem = len - offset;
					memcpy (buf + offset, nextBuffer->GetRemaningBuffer (), rem);
					nextBuffer->offset += rem;
					offset = len; // break
				}
			}
			m_Size -= offset;
		}
		return offset;
	}

	void SendBufferQueue::CleanUp ()
	{