InputStream socketInputStream = socket.getInputStream();
inputStream = new BandwidthCountingInputStream(socketInputStream, 5, TimeUnit.SECONDS);
byte[] buffer = new byte[65536];
- while (true) {
+ while (isRunning()) {
int r = inputStream.read(buffer);
if (r == -1) {
/* yay, eof! */