X-Git-Url: https://git.pterodactylus.net/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fnet%2Fpterodactylus%2Fsonitus%2Fdata%2Fsource%2FMultiSource.java;h=b8afd82edf08354e5723f9e1781229a212767baf;hb=633a841142f978235ed9f745b6ba16c278963e62;hp=21239863299dce47bc6ed726a400a8a21ac71433;hpb=cbeadf6d9eea57ab98cacd60e2419dd3c18bef89;p=sonitus.git

diff --git a/src/main/java/net/pterodactylus/sonitus/data/source/MultiSource.java b/src/main/java/net/pterodactylus/sonitus/data/source/MultiSource.java
index 2123986..b8afd82 100644
--- a/src/main/java/net/pterodactylus/sonitus/data/source/MultiSource.java
+++ b/src/main/java/net/pterodactylus/sonitus/data/source/MultiSource.java
@@ -25,43 +25,63 @@ import java.util.Collections;
 import java.util.List;
 import java.util.concurrent.atomic.AtomicReference;
 import java.util.logging.Logger;
+import javax.swing.event.EventListenerList;
 
-import net.pterodactylus.sonitus.data.AbstractControlledComponent;
+import net.pterodactylus.sonitus.data.AbstractFilter;
 import net.pterodactylus.sonitus.data.Controller;
-import net.pterodactylus.sonitus.data.Source;
-import net.pterodactylus.sonitus.data.event.SourceFinishedEvent;
+import net.pterodactylus.sonitus.data.Filter;
+import net.pterodactylus.sonitus.data.Metadata;
 
-import com.google.common.eventbus.EventBus;
 import com.google.inject.Inject;
 
 /**
- * {@link Source} implementation that simply forwards another source and
- * supports changing the source without letting the {@link
- * net.pterodactylus.sonitus.data.Sink} know.
+ * {@link Filter} implementation that simply forwards data from another filter
+ * and supports changing the source without letting downstream filters know.
  *
  * @author <a href="mailto:bombe@pterodactylus.net">David ‘Bombe’ Roden</a>
  */
-public class MultiSource extends AbstractControlledComponent implements Source {
+public class MultiSource extends AbstractFilter {
 
 	/** The logger. */
 	private static final Logger logger = Logger.getLogger(MultiSource.class.getName());
 
-	/** The event bus. */
-	private final EventBus eventBus;
+	/** The source finished listeners. */
+	private final EventListenerList sourceFinishedListeners = new EventListenerList();
 
 	/** The current source. */
-	private final AtomicReference<Source> source = new AtomicReference<Source>();
+	private final AtomicReference<Filter> source = new AtomicReference<Filter>();
 
 	/** Whether the source was changed. */
 	private boolean sourceChanged;
 
-	/**
-	 * Creates a new multi source.
-	 */
+	/** Creates a new multi source. */
 	@Inject
-	public MultiSource(EventBus eventBus) {
+	public MultiSource() {
 		super("Multisource");
-		this.eventBus = eventBus;
+	}
+
+	//
+	// LISTENER MANAGEMENT
+	//
+
+	/**
+	 * Adds a source finished listener to the list of registered listeners.
+	 *
+	 * @param sourceFinishedListener
+	 * 		The source finished listener to add
+	 */
+	public void addSourceFinishedListener(SourceFinishedListener sourceFinishedListener) {
+		sourceFinishedListeners.add(SourceFinishedListener.class, sourceFinishedListener);
+	}
+
+	/**
+	 * Removes a source finished listener from the list of registered listeners.
+	 *
+	 * @param sourceFinishedListener
+	 * 		The source finished listener to remove
+	 */
+	public void removeSourceFinishedListener(SourceFinishedListener sourceFinishedListener) {
+		sourceFinishedListeners.remove(SourceFinishedListener.class, sourceFinishedListener);
 	}
 
 	//
@@ -74,11 +94,11 @@ public class MultiSource extends AbstractControlledComponent implements Source {
 	 * @param source
 	 * 		The new source to use
 	 */
-	public void setSource(Source source) {
+	public void setSource(Filter source) {
 		checkNotNull(source, "source must not be null");
 
-		Source oldSource = this.source.getAndSet(source);
-		if (oldSource != null) {
+		Filter oldSource = this.source.getAndSet(source);
+		if (!source.equals(oldSource)) {
 			synchronized (this.source) {
 				sourceChanged = true;
 				this.source.notifyAll();
@@ -89,7 +109,23 @@ public class MultiSource extends AbstractControlledComponent implements Source {
 	}
 
 	//
-	// CONTROLLED METHODS
+	// EVENT METHODS
+	//
+
+	/**
+	 * Notifies all registered listeners that the current source finished playing
+	 * and that a new source should be {@link #setSource(Filter) set}.
+	 *
+	 * @see SourceFinishedListener
+	 */
+	private void fireSourceFinished() {
+		for (SourceFinishedListener sourceFinishedListener : sourceFinishedListeners.getListeners(SourceFinishedListener.class)) {
+			sourceFinishedListener.sourceFinished(this);
+		}
+	}
+
+	//
+	// FILTER METHODS
 	//
 
 	@Override
@@ -97,9 +133,15 @@ public class MultiSource extends AbstractControlledComponent implements Source {
 		return Collections.emptyList();
 	}
 
-	//
-	// SOURCE METHODS
-	//
+	@Override
+	public Metadata metadata() {
+		if (super.metadata() == null) {
+			/* no metadata yet, wait for it. */
+			waitForNewSource();
+			sourceChanged = false;
+		}
+		return super.metadata();
+	}
 
 	@Override
 	public byte[] get(int bufferSize) throws EOFException, IOException {
@@ -107,18 +149,7 @@ public class MultiSource extends AbstractControlledComponent implements Source {
 			try {
 				return source.get().get(bufferSize);
 			} catch (EOFException eofe1) {
-				eventBus.post(new SourceFinishedEvent(source.get()));
-				synchronized (source) {
-					while (!sourceChanged) {
-						try {
-							logger.info("Waiting for next Source...");
-							source.wait();
-							logger.info("Was notified.");
-						} catch (InterruptedException ioe1) {
-							/* ignore: we’ll end up here again if we were interrupted. */
-						}
-					}
-				}
+				waitForNewSource();
 			} finally {
 				synchronized (source) {
 					sourceChanged = false;
@@ -127,4 +158,24 @@ public class MultiSource extends AbstractControlledComponent implements Source {
 		}
 	}
 
+	//
+	// PRIVATE METHODS
+	//
+
+	/** Waits for a new source to be {@link #setSource(Filter) set}. */
+	private void waitForNewSource() {
+		fireSourceFinished();
+		synchronized (source) {
+			while (!sourceChanged) {
+				try {
+					logger.info("Waiting for next Source...");
+					source.wait();
+					logger.info("Was notified.");
+				} catch (InterruptedException ioe1) {
+					/* ignore: we’ll end up here again if we were interrupted. */
+				}
+			}
+		}
+	}
+
 }