Commit | Line | Data |
---|---|---|
e018d1ec | 1 | import java.io.*; |
2c648f75 JB |
2 | |
3 | public class ThreadClientReceive implements Runnable { | |
4 | private SocketClient client; | |
2c648f75 JB |
5 | |
6 | ThreadClientReceive(SocketClient c) { | |
7 | client = c; | |
8 | } | |
9 | ||
2c648f75 | 10 | public void run() { |
e018d1ec JB |
11 | try { |
12 | boolean end = false; | |
c4aaaeca | 13 | //FIXME: not exiting properly randomly from that loop! |
e018d1ec JB |
14 | while (!end) { |
15 | String rline = client.receiveMsg(); | |
16 | if (rline.equals(".")) { | |
6b300998 | 17 | end = true; |
e018d1ec JB |
18 | } |
19 | System.out.println(Thread.currentThread().getName() + " a recu " + rline); | |
2c648f75 | 20 | } |
2c648f75 | 21 | } |
e018d1ec JB |
22 | catch (IOException e) { |
23 | System.err.println("IOException: " + e); | |
24 | e.printStackTrace(); | |
25 | } | |
2c648f75 JB |
26 | } |
27 | } |