X-Git-Url: https://git.pterodactylus.net/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fnet%2Fpterodactylus%2Fsonitus%2Fdata%2Ffilter%2FDummyFilter.java;h=ae6899d8e19c3717980c5e3ca57e5d99d95b74ed;hb=cbeadf6d9eea57ab98cacd60e2419dd3c18bef89;hp=a3ce0993299f8e60b5a54920bf10a6c4a851a7df;hpb=7188da95cfb6dc2bf140eb8ac7e4dc99a0761a97;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 a3ce099..ae6899d 100644 --- a/src/main/java/net/pterodactylus/sonitus/data/filter/DummyFilter.java +++ b/src/main/java/net/pterodactylus/sonitus/data/filter/DummyFilter.java @@ -24,7 +24,11 @@ import java.io.OutputStream; import java.io.PipedInputStream; import java.io.PipedOutputStream; 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; @@ -35,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; @@ -43,8 +47,24 @@ 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 + // + + @Override + public List> controllers() { + return Collections.emptyList(); + } // // FILTER METHODS @@ -52,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(); } @@ -68,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();