tact 0.1.1

Terminal interface for Nanocodex
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31

//! Forwarding from subagent runtimes into the TUI event loop.

use crate::core::extensions::subagents::{AgentUpdate, ScopedAgentUpdate, SubagentRuntimeId};
use tokio::sync::mpsc;

pub(crate) struct ForwardedSubagentUpdate {
    pub(crate) runtime_id: SubagentRuntimeId,
    pub(crate) root_session_id: String,
    pub(crate) update: AgentUpdate,
}

pub(crate) fn forward(
    runtime_id: SubagentRuntimeId,
    mut updates: mpsc::UnboundedReceiver<ScopedAgentUpdate>,
    sender: mpsc::UnboundedSender<ForwardedSubagentUpdate>,
) {
    tokio::spawn(async move {
        while let Some(update) = updates.recv().await {
            if sender
                .send(ForwardedSubagentUpdate {
                    runtime_id,
                    root_session_id: update.root_session_id,
                    update: update.update,
                })
                .is_err()
            {
                break;
            }
        }
    });
}