Fix ownership issue in orchestrator streaming

src/orchestrator.rs

@@ -30,13 +30,11 @@ pub struct TriageOutput {
     pub agent_steps: Vec<AgentStep>,
 }
 
-// Non‑streaming version for regular /triage
 pub async fn run_triage(patient_note: &str) -> Result<TriageOutput> {
     let (tx, _) = tokio::sync::mpsc::channel(10);
     run_triage_stream(patient_note.to_string(), tx).await
 }
 
-// Streaming version for /triage/stream
 pub async fn run_triage_stream(
     patient_note: String,
     tx: Sender<Result<Event, Infallible>>,
@@ -78,7 +76,8 @@ pub async fn run_triage_stream(
         .await?;
 
     let mut triage_result = String::new();
-    if resp.status().is_success() {
+    let is_success = resp.status().is_success();
+    if is_success {
         use futures::StreamExt;
         let mut stream = resp.bytes_stream();
         while let Some(chunk) = stream.next().await {
@@ -105,8 +104,8 @@ pub async fn run_triage_stream(
             serde_json::json!({"agent":"Triage","token":&triage_result}).to_string()
         ))).await;
     }
-    let model_used = if resp.status().is_success() { "7B (vLLM)" } else { "mock" };
-    let device_info = if resp.status().is_success() { "ROCm/MI300X" } else { "CPU (fallback)" };
+    let model_used = if is_success { "7B (vLLM)" } else { "mock" };
+    let device_info = if is_success { "ROCm/MI300X" } else { "CPU (fallback)" };
     steps.push(AgentStep {
         name: "Triage".into(),
         status: "completed".into(),