X-Git-Url: https://git.pterodactylus.net/?p=sonitus.git;a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fnet%2Fpterodactylus%2Fsonitus%2Fdata%2Ffilter%2FPipelineFilter.java;fp=src%2Fmain%2Fjava%2Fnet%2Fpterodactylus%2Fsonitus%2Fdata%2Ffilter%2FPipelineFilter.java;h=e4c2d81742e8abdba77730aa692e5ee2197e3a5f;hp=7cc8d9aa2bc942ef72654e58613c48c7e1e8e5c6;hb=a0057669de4cb82f613d0a2a765f145279cf2233;hpb=413a644191719b65fe2730c4689972f50ef7d264 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); }