X-Git-Url: https://git.pterodactylus.net/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fnet%2Fpterodactylus%2Fsonitus%2Fdata%2FConnection.java;h=169bfa57288e16b0c2658f81cc4cae296c78b52c;hb=fb2178b2db851feccfb1a8c278f95b3c2e368cba;hp=8ea1a55a40bb3f74f1177367ade7160bad1e47ff;hpb=db89e5f0aa2506b3e0fe23d0045f86b2c36adca1;p=sonitus.git

diff --git a/src/main/java/net/pterodactylus/sonitus/data/Connection.java b/src/main/java/net/pterodactylus/sonitus/data/Connection.java
index 8ea1a55..169bfa5 100644
--- a/src/main/java/net/pterodactylus/sonitus/data/Connection.java
+++ b/src/main/java/net/pterodactylus/sonitus/data/Connection.java
@@ -56,8 +56,14 @@ public abstract class Connection implements Runnable {
 	@Override
 	public void run() {
 		while (true) {
+			byte[] buffer = null;
+			try {
+				buffer = source.get(bufferSize());
+			} catch (IOException ioe1) {
+				logger.log(Level.WARNING, "Source died!", ioe1);
+				break;
+			}
 			try {
-				byte[] buffer = source.get(bufferSize());
 				feed(buffer);
 			} catch (IOException ioe1) {
 				logger.log(Level.WARNING, "Sink died!", ioe1);