Fix stream_block example: add server.wait() to block until Ctrl+C
This commit is contained in:
@@ -253,6 +253,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
|
|||||||
// Start pmoserver (blocks until Ctrl+C)
|
// Start pmoserver (blocks until Ctrl+C)
|
||||||
tracing::info!("[SERVER] Starting pmoserver...");
|
tracing::info!("[SERVER] Starting pmoserver...");
|
||||||
server.start().await;
|
server.start().await;
|
||||||
|
server.wait().await;
|
||||||
|
|
||||||
// Server stopped, cancel pipeline
|
// Server stopped, cancel pipeline
|
||||||
tracing::info!("Server stopped, canceling pipeline...");
|
tracing::info!("Server stopped, canceling pipeline...");
|
||||||
|
|||||||
Reference in New Issue
Block a user