TcpClient client = TcpClient.create(12012);

Mono<String> res = Mono.create(sink -> {
	client.start(ch -> {
		ch
			.receiveString()
			.next()
			.log("receive")
			.doOnSuccess(sink::success)
			.doOnError(sink::error)
			.subscribe();
		ch
			.sendString(Mono.just("hello"))
			.log("send")
			.doOnError(sink::error)
			.subscribe();
		return Mono.never();
	});
});

res.doOnSuccess(s -> {
	System.out.println(s);
}).block();