TBC

ReactorNet.java

//Create an HTTP Server on 8080
ReactiveNet.httpServer(8080)
            //on HTTP Post matching /hello URI
            .post("/hello", httpChannel -> 
              //echo input to output and close on flush
              httpChannel.writeWith(httpChannel.input())
            )
            //Make sure server is ready before starting client
            .startAndAwait();
  
//Create an HTTP client connecting on started server
ReactiveNet.httpClient()
            //Prepare Post request handling
           .post("http://localhost:8080/hello", httpChannel -> 
              httpChannel.header("foo","bar").writeWith(Publishers.just(Buffer.wrap("World")))
           )
           .subscribe(httpChannel -> 
              httpChannel.input().subscribe(Subscribers.unbounded(Buffer::asString))
           );