Struct FilesWatcher 

pub struct FilesWatcher {
    pool: Arc<FsWatchPool>,
    broker: Arc<Broker>,
    inner: Mutex<Inner>,
}

Fields

pool: Arc<FsWatchPool>

broker: Arc<Broker>

inner: Mutex<Inner>

Implementations

impl FilesWatcher

pub fn new(pool: Arc<FsWatchPool>, broker: Arc<Broker>) -> Arc<Self>

Construct and start the watcher on pool’s shared event stream.

fn lock(&self) -> MutexGuard<'_, Inner>

pub fn watch(&self, dir: &Path, block_id: &str) -> String

Watch the canonical directory dir for block_id; returns the id to unwatch with. Each call is its own registration (the pool reference-counts the OS watch), so two panes on one folder, or one pane watching it twice, never cancel each other.

pub fn unwatch(&self, watch_id: &str)

Stop a watch. An unknown id (already dropped by the cap, or never issued) is not an error.

fn remove_locked(&self, inner: &mut Inner, watch_id: &str)

Drop watch_id from watches and by_dir and release its pool subscription. The caller has already removed it from by_block.

fn on_fs_event(self: &Arc<Self>, path: &Path)

A raw pool event. A change to an entry means its parent folder’s listing changed; a change to a watched folder itself (removed, renamed) is reported for that folder too, so its pane re-lists and finds it gone.

fn on_lagged(self: &Arc<Self>)

fn schedule(self: &Arc<Self>, dir: PathBuf)

Publish for dir once COALESCE from now, unless a publish is already scheduled, in which case this change rides along with it.