# | Line 55 | Line 55 | public class DataReader extends Thread { | |
---|---|---|
55 | // continue until we are told to stop | |
56 | while (_running) { | |
57 | line = _inBound.readLine(); | |
58 | + | if (line == null) { |
59 | + | throw new IOException("unexpected loss of connection to server"); |
60 | + | } |
61 | _dataQueue.add(line); | |
62 | } | |
63 | ||
# | Line 62 | Line 65 | public class DataReader extends Thread { | |
65 | _inBound.close(); | |
66 | ||
67 | } catch (IOException e) { | |
68 | < | SwingClient.addMessage("Data Channel Shutdown: reason - "+e); |
68 | > | Conient.addMessage("WARNING{data reader}: inbound data stopped - "+e); |
69 | _running = false; | |
70 | } | |
71 | } |
– | Removed lines |
+ | Added lines |
< | Changed lines |
> | Changed lines |