diff --git a/pmoparadise/examples/stream_block.rs b/pmoparadise/examples/stream_block.rs
index c463850f..037fe40f 100644
--- a/pmoparadise/examples/stream_block.rs
+++ b/pmoparadise/examples/stream_block.rs
@@ -253,6 +253,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
     // Start pmoserver (blocks until Ctrl+C)
     tracing::info!("[SERVER] Starting pmoserver...");
     server.start().await;
+    server.wait().await;
 
     // Server stopped, cancel pipeline
     tracing::info!("Server stopped, canceling pipeline...");