NettyParser.java

import reactor.netty.DisposableServer;
import reactor.netty.tcp.TcpServer;

public class Application {

	public static void main(String[] args) {
		DisposableServer server =
				TcpServer.create()
					//inbound.connection.addHandlerLast() Is there a combiner I can use here?
				         .handle((inbound, outbound) -> {
					 
					 	//Tried to concat here, but then the flatMap is never called.
					 	//return inbound.receive().asString().reduce(String::concat)
					 
					 
						 return inbound.receive().asString().flatMap(s -> {
						 //this is chunked, but I need the S to be the complete string.
							NettyOutbound out = outbound.sendString(Mono.just(s.toUpperCase()));
							return out
						 })
					 
					 
				         .bindNow();

		server.onDispose()
		      .block();
	}
}