X-Git-Url: https://git.pterodactylus.net/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fnet%2Fpterodactylus%2Fsonitus%2Fdata%2Ffilter%2FDummyFilter.java;h=ae6899d8e19c3717980c5e3ca57e5d99d95b74ed;hb=0cb1a7ef6d41b123f6d0b7db3f17b3d21760c8c8;hp=9d81923aff649ea9d3d1b70957c0a0b3d0ca7e33;hpb=f761d816f6e2f14bc80efb45e4cb5c130fa9a57f;p=sonitus.git diff --git a/src/main/java/net/pterodactylus/sonitus/data/filter/DummyFilter.java b/src/main/java/net/pterodactylus/sonitus/data/filter/DummyFilter.java index 9d81923..ae6899d 100644 --- a/src/main/java/net/pterodactylus/sonitus/data/filter/DummyFilter.java +++ b/src/main/java/net/pterodactylus/sonitus/data/filter/DummyFilter.java @@ -27,6 +27,7 @@ import java.util.Arrays; import java.util.Collections; import java.util.List; +import net.pterodactylus.sonitus.data.AbstractControlledComponent; import net.pterodactylus.sonitus.data.Controller; import net.pterodactylus.sonitus.data.Filter; import net.pterodactylus.sonitus.data.Metadata; @@ -38,7 +39,7 @@ import com.google.common.io.Closeables; * * @author David ‘Bombe’ Roden */ -public class DummyFilter implements Filter { +public class DummyFilter extends AbstractControlledComponent implements Filter { /** The input stream from which to read. */ private InputStream inputStream; @@ -46,8 +47,15 @@ public class DummyFilter implements Filter { /** The output stream to which to write. */ private OutputStream outputStream; - /** The current metadata. */ - private Metadata metadata; + /** + * Creates a new dummy filter with the given name. + * + * @param name + * The name of the filter + */ + public DummyFilter(String name) { + super(name); + } // // CONTROLLED METHODS @@ -64,7 +72,7 @@ public class DummyFilter implements Filter { @Override public void open(Metadata metadata) throws IOException { - this.metadata = metadata; + metadataUpdated(metadata); inputStream = createInputStream(); outputStream = createOutputStream(); } @@ -80,16 +88,6 @@ public class DummyFilter implements Filter { } @Override - public Metadata metadata() { - return metadata; - } - - @Override - public void metadataUpdated(Metadata metadata) { - this.metadata = metadata; - } - - @Override public void process(byte[] buffer) throws IOException { outputStream.write(buffer); outputStream.flush();