Make DCC receiver responsive to stop() requests.
authorDavid ‘Bombe’ Roden <bombe@pterodactylus.net>
Wed, 10 Apr 2013 20:56:03 +0000 (22:56 +0200)
committerDavid ‘Bombe’ Roden <bombe@pterodactylus.net>
Wed, 10 Apr 2013 20:56:03 +0000 (22:56 +0200)
src/main/java/net/pterodactylus/irc/DccReceiver.java

index 58dae01..038f66a 100644 (file)
@@ -150,7 +150,7 @@ public class DccReceiver extends AbstractExecutionThreadService {
                        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! */