Struct LocalFileWatcherSource 

pub struct LocalFileWatcherSource { /* private fields */ }

File system watcher source using notify crate.

Watches a directory for file changes and emits WatchEvents.

Expected Directory Structure

{watch_dir}/
└── scenarios/
    └── {scenario_name}/
        └── sessions/
            └── {timestamp}/
                └── stats.json  <-- triggers event

When a file is created or modified under sessions/, this source extracts the scenario name from the path and emits a WatchEvent.

Implementations

impl LocalFileWatcherSource

pub fn new(watch_dir: &Path, poll_interval: Duration) -> Result<Self, Error>

Create a new file watcher source.

Arguments

• watch_dir - Directory to watch for changes (e.g., ~/.swarm-engine/learning)
• poll_interval - How often to poll for changes (for polling-based backends)

Platform Notes

On macOS/Linux with native FS events, poll_interval is only used as a fallback.

Trait Implementations

impl EventSource for LocalFileWatcherSource

type Event = WatchEvent

Event type produced by this source.

async fn next(&mut self) -> Option<Self::Event>

Get the next event (async, returns None when exhausted).