Function dispatch_streaming

core/src/agent_api/command_runtime.rs:51–69

(
    session: &AgentSession,
    prompt: &str,
)

}

pub(super) async fn dispatch_streaming(
    session: &AgentSession,
    prompt: &str,
) -> Option<(mpsc::Receiver<AgentEvent>, JoinHandle<()>)> {
    if !CommandRegistry::is_command(prompt) {
        return None;
    }

    let ctx = build_command_context(session);
    let output = session_commands::dispatch(session, prompt, &ctx)?;
    let (tx, rx) = mpsc::channel(256);

    let text = output.text;
    let handle = tokio::spawn(async move {
        send_text_output(&tx, text).await;
    });

    Some((rx, handle))
}

fn build_command_context(session: &AgentSession) -> CommandContext {
    let history = read_or_recover(&session.history);