package server;
public class TcpServerConnector extends TcpConnector {
private ServerSocket serverSocket;
private Runnable acceptCallback;
Public TcpServerConnector(ServerSocket s) {
serverSocket = s;
}
public TcpServerConnector(ServerSocket s, Runnable acceptCallback) {
this(s);
this.acceptCallback = acceptCallback;
}
public void establishConnection() throws IOException {
socket = serverSocket.accept();
super.establishConnection();
if(acceptCallback) acceptCallback.run();
}
}