import io.reactivex.netty.codec.StringLineDecoder;
import io.reactivex.netty.examples.AbstractServerExample;
import io.reactivex.netty.protocol.tcp.server.TcpServer;
import java.nio.charset.Charset;
public final class SecureEchoServer extends AbstractServerExample {
<BUG>static TcpServer<ByteBuf, ByteBuf> serverIfRunning;</BUG>
public static void main(final String[] args) {
<BUG>serverIfRunning = TcpServer.newServer(0)
.unsafeSecure()
.start(connection -> connection
.writeStringAndFlushOnEach(connection.getInput()

.map(bb -> bb.toString(
Charset.defaultCharset()))</BUG>
.doOnNext(logger::error)

import io.reactivex.netty.codec.StringLineDecoder;
import io.reactivex.netty.examples.AbstractServerExample;
import io.reactivex.netty.protocol.tcp.server.TcpServer;
import java.nio.charset.Charset;
public final class SecureEchoServer extends AbstractServerExample {
public static void main(final String[] args) {
TcpServer<ByteBuf, ByteBuf> server = TcpServer.newServer(0)
.unsafeSecure()
.start(connection ->
connection.writeStringAndFlushOnEach(connection.getInput()
.map(bb -> bb.toString(Charset.defaultCharset()))
.doOnNext(logger::error)
