X-Git-Url: https://git.pterodactylus.net/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fnet%2Fpterodactylus%2Fsonitus%2Fdata%2Ffilter%2FPipelineFilter.java;h=e4c2d81742e8abdba77730aa692e5ee2197e3a5f;hb=a0057669de4cb82f613d0a2a765f145279cf2233;hp=638df00b1097cd2fc6a9d1caaa8583d05c88400d;hpb=48ff2dfc3ec8aafa119b8e25dade695c5d40312b;p=sonitus.git

diff --git a/src/main/java/net/pterodactylus/sonitus/data/filter/PipelineFilter.java b/src/main/java/net/pterodactylus/sonitus/data/filter/PipelineFilter.java
index 638df00..e4c2d81 100644
--- a/src/main/java/net/pterodactylus/sonitus/data/filter/PipelineFilter.java
+++ b/src/main/java/net/pterodactylus/sonitus/data/filter/PipelineFilter.java
@@ -92,10 +92,14 @@ public class PipelineFilter extends AbstractFilter implements Filter {
 			new Thread(connection, threadName).start();
 			currentSource = filter;
 		}
+		metadataUpdated(currentMetadata);
 	}
 
 	@Override
 	public DataPacket get(int bufferSize) throws IOException {
+		if (filterConnections.get(lastFilter).ioException().isPresent()) {
+			throw filterConnections.get(lastFilter).ioException().get();
+		}
 		return lastFilter.get(bufferSize);
 	}