Method startAsyncRead

src/eepp/network/tcpsocket.cpp:346–366

}

void TcpSocket::startAsyncRead( ReadFn readFn ) {
	mReadThread = std::thread( [this, readFn] {
		setReceiveTimeout( Milliseconds( 100 ) );
		std::string buffer;
		buffer.resize( 131072 );
		Clock clock;
		while ( mSocket != Private::SocketImpl::invalidSocket() ) {
			size_t received = 0;
			clock.restart();
			while ( receive( buffer.data(), buffer.size(), received ) == Status::Done &&
					received > 0 )
				readFn( buffer.c_str(), received );
			if ( mSocket != Private::SocketImpl::invalidSocket() &&
				 clock.getElapsedTime().asMilliseconds() < 100.f ) {
				auto ms = 100.f - clock.getElapsedTime().asMilliseconds();
				Sys::sleep( Milliseconds( ms ) );
			}
			clock.restart();
		}
	} );
}

TcpSocket::PendingPacket::PendingPacket() : Size( 0 ), SizeReceived( 0 ), Data() {}