diff --git a/poc-agent/src/observe.rs b/poc-agent/src/observe.rs
index a5bd127..e5f0c29 100644
--- a/poc-agent/src/observe.rs
+++ b/poc-agent/src/observe.rs
@@ -128,9 +128,13 @@ pub async fn cmd_read_inner(follow: bool, block: bool, debug: bool) -> anyhow::R
                 print!("{}", line);
                 let _ = std::io::stdout().lock().flush();
                 
-                // In blocking mode, stop when we see a new user input (line starting with ">")
-                if block && line.trim_start().starts_with('>') {
-                    break;
+                // In blocking mode, stop when we see a new user input
+                // Format: "> X: " where X is a speaker (P, K, etc.)
+                if block && line.trim_start().starts_with("> ") {
+                    let after_gt = line.trim_start().strip_prefix("> ").unwrap_or("");
+                    if after_gt.contains(':') {
+                        break;
+                    }
                 }
             }
             Err(_) => break,