X-Git-Url: https://git.pterodactylus.net/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fnet%2Fpterodactylus%2Fsonitus%2Fdata%2Ffilter%2FMultiSourceFilter.java;h=704324dc9cfe29eed29b5895aef3971e3cce782b;hb=c10b4f2fdb1e55b1c9dbb996ecee4a306d1481b0;hp=3c3dc7aa461d4522d0bdecf73aa4f034cf92282a;hpb=cea54dd0028f59f9d670f7941366d96848fb25f7;p=sonitus.git

diff --git a/src/main/java/net/pterodactylus/sonitus/data/filter/MultiSourceFilter.java b/src/main/java/net/pterodactylus/sonitus/data/filter/MultiSourceFilter.java
index 3c3dc7a..704324d 100644
--- a/src/main/java/net/pterodactylus/sonitus/data/filter/MultiSourceFilter.java
+++ b/src/main/java/net/pterodactylus/sonitus/data/filter/MultiSourceFilter.java
@@ -34,6 +34,7 @@ import net.pterodactylus.sonitus.data.Filter;
 import net.pterodactylus.sonitus.data.Format;
 import net.pterodactylus.sonitus.data.ReusableSink;
 import net.pterodactylus.sonitus.data.Source;
+import net.pterodactylus.sonitus.data.event.SourceFinishedEvent;
 
 import com.google.common.eventbus.EventBus;
 import com.google.inject.Inject;
@@ -133,6 +134,9 @@ public class MultiSourceFilter implements Filter, ReusableSink {
 		 */
 		public Connection source(Source source) throws IOException {
 			synchronized (syncObject) {
+				if (this.source != null) {
+					eventBus.post(new SourceFinishedEvent(this.source));
+				}
 				this.source = source;
 				pipedInputStream = new PipedInputStream();
 				pipedOutputStream = new PipedOutputStream(pipedInputStream);