.doOnSubscribe(WELCOME_MSG_BUFFER::retain);
private static final String CONTENT_LENGTH_HEADER_VAL = String.valueOf(WELCOME_MSG_BUFFER.readableBytes());
public static void main(final String[] args) {
RxNetty.disableEventPublishing();
HttpServer<ByteBuf, ByteBuf> server;
<BUG>server = HttpServer.newServer()
.start((req, resp) -></BUG>
resp.setHeader(CONTENT_LENGTH, CONTENT_LENGTH_HEADER_VAL)
.flushOnlyOnReadComplete()
.write(RESPONSE_CONTENT)

.doOnSubscribe(WELCOME_MSG_BUFFER::retain);
private static final String CONTENT_LENGTH_HEADER_VAL = String.valueOf(WELCOME_MSG_BUFFER.readableBytes());
public static void main(final String[] args) {
RxNetty.disableEventPublishing();
HttpServer<ByteBuf, ByteBuf> server;
server = HttpServer.newServer()
.enableWireLogging(LogLevel.DEBUG)
.start((req, resp) ->
resp.setHeader(CONTENT_LENGTH, CONTENT_LENGTH_HEADER_VAL)
.flushOnlyOnReadComplete()
.write(RESPONSE_CONTENT)
