| 26 | namespace Mona { |
| 27 | |
| 28 | TCPClient::TCPClient(const SocketManager& manager) : _disconnecting(false),_pBuffer(manager.poolBuffers), _socket(manager), |
| 29 | onReadable([this](Exception& ex, UInt32 available) {receive(ex,available);}), |
| 30 | onSending([this](UInt32 size) {lock_guard<mutex> lock(_mutexIdleTime); _idleTime.update(); }) { |
| 31 | _socket.OnError::subscribe(*this); |
| 32 | _socket.OnSending::subscribe(onSending); |
| 33 | _socket.OnReadable::subscribe(onReadable); |
| 34 | } |
| 35 | |
| 36 | TCPClient::TCPClient(const SocketAddress& peerAddress, SocketFile& file,const SocketManager& manager) : _disconnecting(false),_peerAddress(peerAddress),_pBuffer(manager.poolBuffers), _socket(file,manager), |
| 37 | onReadable([this](Exception& ex, UInt32 available) {receive(ex,available);}), |