Struct ConversationWatcher 

pub struct ConversationWatcher { /* private fields */ }

Watches a Gemini conversation for new turns and tool-call updates.

Example

use toolpath_gemini::{GeminiConvo, ConversationWatcher};
use toolpath_convo::WatcherEvent;

let manager = GeminiConvo::new();
let mut watcher = ConversationWatcher::new(
    manager,
    "/path/to/project".to_string(),
    "session-uuid".to_string(),
);
let events = watcher.poll().unwrap();
for event in events {
    match event {
        WatcherEvent::Turn(t) => println!("new: {}", t.text),
        WatcherEvent::TurnUpdated(t) => println!("updated: {}", t.id),
        WatcherEvent::Progress { kind, data } => println!("{}: {}", kind, data),
    }
}

Implementations

impl ConversationWatcher

pub fn new(manager: GeminiConvo, project: String, session_uuid: String) -> Self

pub fn project(&self) -> &str

pub fn session_uuid(&self) -> &str

pub fn seen_count(&self) -> usize

Total turns emitted so far across all chat files in this session.

pub fn reset(&mut self)

Reset state so the next poll returns all messages from scratch.

pub fn poll(&mut self) -> Result<Vec<WatcherEvent>>

Poll for new events.

On the first call, emits one Turn event per existing message, plus one subagent_started/subagent_complete per pre-existing sub-agent file. Subsequent calls emit only new messages, status updates, and new sub-agent files.

pub fn poll_with_view( &mut self, ) -> Result<(ConversationView, Vec<WatcherEvent>)>

Re-read the full session and return a fresh ConversationView along with the new events emitted since the last poll.

Useful when consumers need both the delta and the full state.

Trait Implementations

impl ConversationWatcher for ConversationWatcher

fn poll(&mut self) -> Result<Vec<WatcherEvent>>

Poll for new events since the last poll.

fn seen_count(&self) -> usize

Number of turns seen so far.

impl Debug for ConversationWatcher

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.