From a0057669de4cb82f613d0a2a765f145279cf2233 Mon Sep 17 00:00:00 2001 From: =?utf8?q?David=20=E2=80=98Bombe=E2=80=99=20Roden?= Date: Thu, 6 Jun 2013 06:38:04 +0200 Subject: [PATCH] If a connection within this filter has caught an exception, rethrow it here. --- .../java/net/pterodactylus/sonitus/data/filter/PipelineFilter.java | 3 +++ 1 file changed, 3 insertions(+) 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 --- 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); } -- 2.7.4