X-Git-Url: https://git.pterodactylus.net/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fnet%2Fpterodactylus%2Fsonitus%2Fdata%2Fsource%2FMultiSource.java;h=1d8f289c0417a85de48778a5656f932676d3dbb6;hb=87436ac0b103a112722c1df835e11ec928e57d38;hp=b5705d5a76e6d144a6bcb4862e4dabc7d155d1f9;hpb=7188da95cfb6dc2bf140eb8ac7e4dc99a0761a97;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 b5705d5..1d8f289 100644 --- a/src/main/java/net/pterodactylus/sonitus/data/source/MultiSource.java +++ b/src/main/java/net/pterodactylus/sonitus/data/source/MultiSource.java @@ -21,11 +21,16 @@ import static com.google.common.base.Preconditions.checkNotNull; import java.io.EOFException; import java.io.IOException; +import java.util.Collections; +import java.util.List; import java.util.concurrent.atomic.AtomicReference; import java.util.logging.Logger; +import net.pterodactylus.sonitus.data.AbstractControlledComponent; +import net.pterodactylus.sonitus.data.Controller; import net.pterodactylus.sonitus.data.Metadata; import net.pterodactylus.sonitus.data.Source; +import net.pterodactylus.sonitus.data.event.MetadataUpdated; import net.pterodactylus.sonitus.data.event.SourceFinishedEvent; import com.google.common.eventbus.EventBus; @@ -38,7 +43,7 @@ import com.google.inject.Inject; * * @author David ‘Bombe’ Roden */ -public class MultiSource implements Source { +public class MultiSource extends AbstractControlledComponent implements Source { /** The logger. */ private static final Logger logger = Logger.getLogger(MultiSource.class.getName()); @@ -52,6 +57,12 @@ public class MultiSource implements Source { /** Whether the source was changed. */ private boolean sourceChanged; + /** + * Creates a new multi source. + * + * @param eventBus + * The event bus + */ @Inject public MultiSource(EventBus eventBus) { this.eventBus = eventBus; @@ -76,11 +87,27 @@ public class MultiSource implements Source { sourceChanged = true; this.source.notifyAll(); } + fireMetadataUpdated(source.metadata()); + eventBus.post(new MetadataUpdated(this, source.metadata())); logger.info(String.format("Next Source set: %s", source)); } } // + // CONTROLLED METHODS + // + + @Override + public String name() { + return "Multisource"; + } + + @Override + public List> controllers() { + return Collections.emptyList(); + } + + // // SOURCE METHODS //