X-Git-Url: https://git.pterodactylus.net/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fnet%2Fpterodactylus%2Fsonitus%2Fdata%2Fsink%2FAudioSink.java;h=f29bde8b263e4e602d0932fac13d70af9cac2b11;hb=a669196536534aa133343982d9c7600253fbf4a8;hp=b3aa7e7860cd9ba64c3f01863a15132f494f12ec;hpb=fb2178b2db851feccfb1a8c278f95b3c2e368cba;p=sonitus.git

diff --git a/src/main/java/net/pterodactylus/sonitus/data/sink/AudioSink.java b/src/main/java/net/pterodactylus/sonitus/data/sink/AudioSink.java
index b3aa7e7..f29bde8 100644
--- a/src/main/java/net/pterodactylus/sonitus/data/sink/AudioSink.java
+++ b/src/main/java/net/pterodactylus/sonitus/data/sink/AudioSink.java
@@ -42,9 +42,12 @@ public class AudioSink implements Sink {
 	/** The logger. */
 	private static final Logger logger = Logger.getLogger(AudioSink.class.getName());
 
+	/** The current source. */
+	private Source source;
+
 	@Override
 	public void connect(Source source) throws ConnectException {
-		checkNotNull(source, "source must not be null");
+		this.source = checkNotNull(source, "source must not be null");
 		checkState(source.metadata().encoding().equalsIgnoreCase("PCM"), "source must be PCM-encoded");
 
 		final Metadata sourceMetadata = source.metadata();
@@ -71,6 +74,7 @@ public class AudioSink implements Sink {
 					sourceDataLine.stop();
 				}
 			}).start();
+			metadataUpdated();
 		} catch (LineUnavailableException lue1) {
 			throw new ConnectException(lue1);
 		}