If a connection within this filter has caught an exception, rethrow it here.

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 7cc8d9a..e4c2d81 100644 (file)
--- a/src/main/java/net/pterodactylus/sonitus/data/filter/PipelineFilter.java
+++ b/src/main/java/net/pterodactylus/sonitus/data/filter/PipelineFilter.java
@@ -97,6 +97,9 @@ public class PipelineFilter extends AbstractFilter implements Filter {
 
        @Override
        public DataPacket get(int bufferSize) throws IOException {
+               if (filterConnections.get(lastFilter).ioException().isPresent()) {
+                       throw filterConnections.get(lastFilter).ioException().get();
+               }
                return lastFilter.get(bufferSize);
        }