Function stream_session_request

sdk/node/src/lib.rs:871–898

(
    session: Arc<RustAgentSession>,
    prompt: String,
    history: Option<Vec<RustMessage>>,
    attachments: Vec<a3s_code_core::llm::Attachment>,
)

}

async fn stream_session_request(
    session: Arc<RustAgentSession>,
    prompt: String,
    history: Option<Vec<RustMessage>>,
    attachments: Vec<a3s_code_core::llm::Attachment>,
) -> napi::Result<EventStream> {
    let (rx, _handle) = if attachments.is_empty() {
        get_runtime()
            .spawn(async move { session.stream(&prompt, history.as_deref()).await })
            .await
            .map_err(|e| napi::Error::from_reason(format!("Task join error: {e}")))?
    } else {
        get_runtime()
            .spawn(async move {
                session
                    .stream_with_attachments(&prompt, &attachments, history.as_deref())
                    .await
            })
            .await
            .map_err(|e| napi::Error::from_reason(format!("Task join error: {e}")))?
    }
    .map_err(|e| napi::Error::from_reason(format!("Failed to start stream: {e}")))?;

    Ok(EventStream {
        rx: Arc::new(tokio::sync::Mutex::new(rx)),
        done: Arc::new(AtomicBool::new(false)),
    })
}

fn tool_result_from_core(result: a3s_code_core::ToolCallResult) -> ToolResult {
    ToolResult {