X-Git-Url: https://git.pterodactylus.net/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fnet%2Fpterodactylus%2Fsonitus%2Fdata%2Ffilter%2FExternalFilter.java;h=73d4b5f29d51cb709af68d331e323c2b6946a2da;hb=ab9e62794abd0430bf2c79ecd41e311675d8b7c4;hp=497ba2ab289144f7e2f3ca698713f6abeb1f45c5;hpb=c10b4f2fdb1e55b1c9dbb996ecee4a306d1481b0;p=sonitus.git

diff --git a/src/main/java/net/pterodactylus/sonitus/data/filter/ExternalFilter.java b/src/main/java/net/pterodactylus/sonitus/data/filter/ExternalFilter.java
index 497ba2a..73d4b5f 100644
--- a/src/main/java/net/pterodactylus/sonitus/data/filter/ExternalFilter.java
+++ b/src/main/java/net/pterodactylus/sonitus/data/filter/ExternalFilter.java
@@ -49,8 +49,8 @@ public abstract class ExternalFilter implements Filter {
 	/** The logger. */
 	private final Logger logger = Logger.getLogger(getClass().getName());
 
-	/** The format of the source. */
-	private Format format;
+	/** The source. */
+	private Source source;
 
 	/** The input stream that will hold the converted source. */
 	private PipedInputStream pipedInputStream;
@@ -61,7 +61,7 @@ public abstract class ExternalFilter implements Filter {
 
 	@Override
 	public Format format() {
-		return format;
+		return source.format();
 	}
 
 	@Override
@@ -78,9 +78,9 @@ public abstract class ExternalFilter implements Filter {
 	public void connect(Source source) throws ConnectException {
 		Preconditions.checkNotNull(source, "source must not be null");
 
-		format = source.format();
+		this.source = source;
 		try {
-			final Process process = Runtime.getRuntime().exec(Iterables.toArray(ImmutableList.<String>builder().add(binary(format)).addAll(parameters(format)).build(), String.class));
+			final Process process = Runtime.getRuntime().exec(Iterables.toArray(ImmutableList.<String>builder().add(binary(source.format())).addAll(parameters(source.format())).build(), String.class));
 			final InputStream processOutput = process.getInputStream();
 			final OutputStream processInput = process.getOutputStream();
 			final InputStream processError = process.getErrorStream();