diff --git a/tests/test_metadata_stream.liq b/tests/test_metadata_stream.liq
index 1df5ad9a7d1dcbcdac0b06aa86baf678191e3931..8f55d5d57243cd261d6a9d359cdfa6c548ed28ea 100755
--- a/tests/test_metadata_stream.liq
+++ b/tests/test_metadata_stream.liq
@@ -19,16 +19,22 @@
 
 
 %include "base_config.liq"
-settings.frame.audio.samplerate.set(44100)
 
-# Metadata on stream
-stream_url = "https://securestream.o94.at/live.mp3"
-annotated_uri = 'in_http_0.url annotate:show_name="XXX":#{stream_url}'
-input_stream = input.http(id="input_stream", start=false, annotated_uri)
-def process(metadata) =
-    print(json.stringify(metadata))
-    assertEquals(metadata["show_name"], "XXX")
+
+# Test insert metadata on stream
+url = "https://securestream.o94.at/live.mp3"
+in_stream = input.http(id="in_stream", start=true, url)
+in_stream = insert_metadata(id="in_stream", in_stream)
+def on_metadata_notification(metadata) =
+    print("METADATA: \n#{metadata}")
 end
-input_stream.on_metadata(process)
-output.dummy(id="dummy", input_stream, fallible=true)
-input_stream.start()
+
+# Save the callback
+imcb = in_stream.insert_metadata
+
+in_stream = source.on_metadata(id="in_stream", in_stream, on_metadata_notification)
+output.alsa(id="lineout", device="default", mksafe(in_stream))
+
+# Later:
+meta = [("foo", "bar")]
+thread.run(every=3., { imcb(meta) })