Struct FileWatcherNode 

pub struct FileWatcherNode<Context, Action>
where
    Context: Send + Sync + 'static,
    Action: ActionType + Send + Sync + 'static + Debug,
{ /* private fields */ }

A node that watches a file for changes

Implementations

impl<Context, Action> FileWatcherNode<Context, Action>

where Context: Send + Sync + 'static, Action: ActionType + Send + Sync + 'static + Debug,

pub fn new<P: Into<String>>(file_path: P) -> Self

Create a new file watcher node

pub fn with_id<P: Into<String>>(file_path: P) -> Self

Create a new file watcher node with a specified ID

pub fn with_poll_interval(self, interval: Duration) -> Self

Set the poll interval for the file watcher

pub fn with_change_handler<F, Fut>(self, handler: F) -> Self

where F: Fn(FileChange, &mut Context) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<Action, FloxideError>> + Send + 'static,

Set the change handler for the file watcher node

Trait Implementations

impl<Context, Action> ReactiveNode<FileChange, Context, Action> for FileWatcherNode<Context, Action>

where Context: Send + Sync + 'static, Action: ActionType + Send + Sync + 'static + Debug,

fn react_to_change<'life0, 'life1, 'async_trait>( &'life0 self, change: FileChange, context: &'life1 mut Context, ) -> Pin<Box<dyn Future<Output = Result<Action, FloxideError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Reacts to a file change and produces an action

fn watch<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Box<dyn Stream<Item = FileChange> + Send + Unpin>, FloxideError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Set up a stream of changes to watch

fn id(&self) -> NodeId

Get the node’s unique identifier