cc-14.java

public void propagate(Object message) {
  new Thread(() -> {
    for (InetAddress ip : peers) {
      // Abrir socket hacia el nodo
      Socket s = new Socket();
      s.connect(
        new InetSocketAddress(ip, Cutrecoin.PORT),
        Cutrecoin.TIMEOUT);
      ObjectOutputStream outputStream =
        new ObjectOutputStream(s.getOutputStream());
      ObjectInputStream inputStream =
        new ObjectInputStream(s.getInputStream());
      // Enviar mensaje
      send(outputStream, message);
      // Esperar una posible respuesta
      Object response = inputStream.readObject();
      onNewMessage(outputStream, response);
      // Cerrar socket
      s.close();
    }
  }).start();
}