diff --git a/src/main/java/ch/unibas/dmi/dbis/cs108/casono/server/ServerApp.java b/src/main/java/ch/unibas/dmi/dbis/cs108/casono/server/ServerApp.java index d4cc99b..ad90416 100644 --- a/src/main/java/ch/unibas/dmi/dbis/cs108/casono/server/ServerApp.java +++ b/src/main/java/ch/unibas/dmi/dbis/cs108/casono/server/ServerApp.java @@ -9,11 +9,13 @@ import ch.unibas.dmi.dbis.cs108.casono.server.network.sessions.SessionManager; public class ServerApp { public static void start(String arg) { int port = Integer.parseInt(arg); - System.out.println("You've selected the server. It will accept connections at port " + port); + System.out.println( + "You've selected the server. It will accept connections at port " + port); EventBus eventBus = new EventBus(); SessionManager sessionManager = new SessionManager(); - eventBus.subscribe(DisconnectEvent.class, event -> sessionManager.removeSession(event.sessionId())); + eventBus.subscribe( + DisconnectEvent.class, event -> sessionManager.removeSession(event.sessionId())); NetworkManager networkManager = new NetworkManager(port, sessionManager, eventBus); networkManager.start(); } diff --git a/src/main/java/ch/unibas/dmi/dbis/cs108/casono/server/network/NetworkManager.java b/src/main/java/ch/unibas/dmi/dbis/cs108/casono/server/network/NetworkManager.java index d962139..faa2ebd 100644 --- a/src/main/java/ch/unibas/dmi/dbis/cs108/casono/server/network/NetworkManager.java +++ b/src/main/java/ch/unibas/dmi/dbis/cs108/casono/server/network/NetworkManager.java @@ -58,8 +58,9 @@ public class NetworkManager implements Runnable { try (ServerSocket serverSocket = new ServerSocket(port)) { while (running) { Socket clientSocket = serverSocket.accept(); - - System.out.println("Accepted connection from " + clientSocket.getRemoteSocketAddress()); + + System.out.println( + "Accepted connection from " + clientSocket.getRemoteSocketAddress()); Session session = new Session(new TcpTransport(clientSocket), eventBus); sessionManager.addSession(session); diff --git a/src/main/java/ch/unibas/dmi/dbis/cs108/casono/server/network/events/EventBus.java b/src/main/java/ch/unibas/dmi/dbis/cs108/casono/server/network/events/EventBus.java index b5e3457..eb4293d 100644 --- a/src/main/java/ch/unibas/dmi/dbis/cs108/casono/server/network/events/EventBus.java +++ b/src/main/java/ch/unibas/dmi/dbis/cs108/casono/server/network/events/EventBus.java @@ -17,7 +17,9 @@ public class EventBus { * @param eventType the class of the event to subscribe to * @param handler the consumer to handle the event */ - @SuppressWarnings("unchecked") // This cast is safe, because handlers only get passed the type they subscribed to + @SuppressWarnings( + "unchecked") // This cast is safe, because handlers only get passed the type they + // subscribed to public void subscribe(Class eventType, Consumer handler) { handlers.computeIfAbsent(eventType, k -> new CopyOnWriteArrayList<>()) .add((Consumer) (Consumer) handler);