vibe-core/tests/vibe.core.net.1441/source/app.d

import vibe.core.core;
import vibe.core.net;
import core.time : msecs;
import std.string : representation;

void main()
{
	import vibe.core.log;
	bool done = false;
	listenTCP(11375, (conn) {
		try {
			conn.write("foo".representation);
			conn.close();
		} catch (Exception e) {
			assert(false, e.msg);
		}
		done = true;
	});

	runTask({
		auto conn = connectTCP("127.0.0.1", 11375);
		conn.close();

		sleep(50.msecs);
		assert(done);

		exitEventLoop();
	});

	runEventLoop();
}