From 55c66f0462c25378187f0523c4db06ebdaec7187 Mon Sep 17 00:00:00 2001
From: Claude <noreply@anthropic.com>
Date: Tue, 11 Nov 2025 20:03:49 +0000
Subject: [PATCH] Fix stream_block example: add server.wait() to block until
 Ctrl+C

---
 pmoparadise/examples/stream_block.rs | 1 +
 1 file changed, 1 insertion(+)

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...");