Struct EventLoop 

pub struct EventLoop {
    pub rx: Receiver<TuiEvent>,
    pub app_tx: Sender<ApprovalResult>,
    pub cmd_tx: Sender<(usize, String)>,
    pub agent: Arc<Mutex<DeepSeekAgent>>,
    pub cancel_token: Arc<Mutex<CancellationToken>>,
    pub run_id: Arc<AtomicUsize>,
}

Fields

rx: Receiver<TuiEvent>

app_tx: Sender<ApprovalResult>

cmd_tx: Sender<(usize, String)>

agent: Arc<Mutex<DeepSeekAgent>>

cancel_token: Arc<Mutex<CancellationToken>>

Shared cancel token — can be cancelled without locking the agent mutex

run_id: Arc<AtomicUsize>

Implementations

impl EventLoop

pub fn new( rx: Receiver<TuiEvent>, _rx_tx: Sender<TuiEvent>, app_tx: Sender<ApprovalResult>, cmd_tx: Sender<(usize, String)>, agent: Arc<Mutex<DeepSeekAgent>>, cancel_token: Arc<Mutex<CancellationToken>>, run_id: Arc<AtomicUsize>, ) -> Self

pub async fn run(self) -> Result<String>

impl EventLoop

pub fn handle_input( &self, app: &mut App, stdout: &mut Stdout, key: KeyEvent, ) -> Result<bool>

pub fn handle_agent_event( &self, app: &mut App, stdout: &mut Stdout, agent_event: AgentEvent, full_message: &mut String, reasoning_colorizer: &mut StreamColorizer, content_colorizer: &mut StreamColorizer, ) -> Result<()>