code: public static void main(String[] args) throws Exception {
  		Eventloop eventloop = Eventloop.create().withCurrentThread();
  
  		SimpleServer server = SimpleServer.create(socket ->
  				BinaryChannelSupplier.of(ChannelSupplier.ofSocket(socket))
  						.parseStream(ByteBufsParser.ofCrlfTerminatedBytes())
  						.peek(buf -> System.out.println("client:" + buf.getString(UTF_8)))
  						.map(buf -> {
  							ByteBuf serverBuf = ByteBufStrings.wrapUtf8("Server> ");
  							return ByteBufPool.append(serverBuf, buf);
  						})
  						.map(buf -> ByteBufPool.append(buf, CRLF))
  						.streamTo(ChannelConsumer.ofSocket(socket)))
  				.withListenPort(PORT);
  
  		server.listen();
  
  		System.out.println("Server is running");
  		System.out.println("You can connect from telnet with command: telnet localhost 9922 or by running TcpClientExample");
  
  		eventloop.run();
  	}
docs: /* Run server in an event loop.