Struct AsyncConversationWatcher 

pub struct AsyncConversationWatcher { /* private fields */ }

Async conversation watcher that uses filesystem events with a periodic fallback poll for reliability.

Implementations

impl AsyncConversationWatcher

pub fn new(file_path: PathBuf, config: Option<WatcherConfig>) -> Self

Create a new async watcher for a conversation file.

Arguments

• file_path - Path to the JSONL conversation file
• config - Optional configuration (uses defaults if None)

pub fn with_offset( file_path: PathBuf, offset: u64, config: Option<WatcherConfig>, ) -> Self

Create a watcher starting from a specific byte offset. Useful for resuming watching after a restart.

pub async fn offset(&self) -> u64

Get the current byte offset

pub async fn poll(&self) -> Result<Vec<ConversationEntry>>

Check for new entries since last read (non-blocking poll). Returns new entries and updates internal offset.

pub async fn start( self, tx: Sender<Vec<ConversationEntry>>, ) -> Result<WatcherHandle>

Start watching the file and send new entries to the provided channel. This spawns a background task that:

1. Watches for filesystem modify events
2. Polls periodically as a safety fallback

Returns a handle that can be used to stop the watcher.