| # | 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 | ||
| – | Removed lines |
| + | Added lines |
| < | Changed lines |
| > | Changed lines |