Method TCPConnection

UnitTests/sources/SocketTest.cpp:230–245

class TCPConnection {
public:
	TCPConnection(const SocketAddress& peerAddress,SocketFile& file,const SocketManager& manager) : _client(peerAddress,file, manager) {
		onData = [this](PoolBuffer& pBuffer) {
			Exception ex;
			CHECK(_client.send(ex, pBuffer->data(), pBuffer->size()) && !ex);
			return pBuffer->size();
		};
		onError = [this](const Exception& ex) {
			FATAL_ERROR("Client, ",ex.error());
		};
		onDisconnection = [this](TCPClient& client, const SocketAddress& peerAddress){
			CHECK(!_client.connected());
		};
		_client.OnError::subscribe(onError);
		_client.OnData::subscribe(onData);
		_client.OnDisconnection::subscribe(onDisconnection);
	}

	~TCPConnection() {
		_client.OnError::unsubscribe(onError);