Streaming markdown

crates/goose-cli/Cargo.toml

@@ -61,6 +61,7 @@ open = "5.3.2"
 url = { workspace = true }
 urlencoding = { workspace = true }
 clap_complete = "4.5.62"
+comfy-table = "7.2.2"
 
 [target.'cfg(target_os = "windows")'.dependencies]
 winapi = { version = "0.3", features = ["wincred"] }

crates/goose-cli/src/session/mod.rs

@@ -5,6 +5,7 @@ mod elicitation;
 mod export;
 mod input;
 mod output;
+pub mod streaming_buffer;
 mod task_execution_display;
 mod thinking;
 
@@ -961,6 +962,7 @@ impl CliSession {
 
         let mut progress_bars = output::McpSpinners::new();
         let cancel_token_clone = cancel_token.clone();
+        let mut markdown_buffer = streaming_buffer::MarkdownBuffer::new();
 
         use futures::StreamExt;
         loop {
@@ -1033,7 +1035,7 @@ impl CliSession {
                                 if is_stream_json_mode {
                                     emit_stream_event(&StreamEvent::Message { message: message.clone() });
                                 } else if !is_json_mode {
-                                    output::render_message(&message, self.debug);
+                                    output::render_message_streaming(&message, &mut markdown_buffer, self.debug);
                                 }
                             }
                         }
@@ -1087,6 +1089,10 @@ impl CliSession {
             }
         }
 
+        if !is_json_mode && !is_stream_json_mode {
+            output::flush_markdown_buffer_current_theme(&mut markdown_buffer);
+        }
+
         if is_json_mode {
             let metadata = match self
                 .agent