public static void receive()

in example/EchoService.java [10:27]

18 lines of code
3 McCabe index (conditional complexity)


  public static void receive(int port) {
    try (ServerSocket sock = new ServerSocket(port)) {
      System.out.println("Listening on port " + port);
      while (!Thread.currentThread().isInterrupted()) {
        try (Socket client = sock.accept()) {
          InputStream inputStream = client.getInputStream();
          ObjectInputStream objectInputStream = new ObjectInputStream(inputStream);
          String msg = (String) objectInputStream.readObject();
          System.out.println("Received message " + msg);
          ObjectOutputStream objectOutputStream = new ObjectOutputStream(client.getOutputStream());
          objectOutputStream.writeObject(msg);
        }
      }
    } catch (IOException | ClassNotFoundException e) {
      e.printStackTrace();
      throw new IllegalStateException(e);
    }
  }