diff --git a/examples/poll_sysfs.rs b/examples/poll_sysfs.rs index 28d80a2c..11d531cd 100644 --- a/examples/poll_sysfs.rs +++ b/examples/poll_sysfs.rs @@ -1,48 +1,52 @@ -use std::path::Path; -use std::time::Duration; use notify::poll::PollWatcherConfig; use notify::{PollWatcher, RecursiveMode, Watcher}; +use std::path::Path; +use std::time::Duration; #[cfg(not(target_os = "windows"))] fn not_windows_main() -> notify::Result<()> { - let mut paths: Vec<_> = std::env::args().skip(1) - .map(|arg| Path::new(&arg).to_path_buf()) - .collect(); - if paths.is_empty() { - let lo_stats = Path::new("/sys/class/net/lo/statistics/tx_bytes").to_path_buf(); - if !lo_stats.exists() { - eprintln!("Must provide path to watch, default system path was not found (probably you're not running on Linux?)"); - std::process::exit(1); + let mut paths: Vec<_> = std::env::args() + .skip(1) + .map(|arg| Path::new(&arg).to_path_buf()) + .collect(); + if paths.is_empty() { + let lo_stats = Path::new("/sys/class/net/lo/statistics/tx_bytes").to_path_buf(); + if !lo_stats.exists() { + eprintln!("Must provide path to watch, default system path was not found (probably you're not running on Linux?)"); + std::process::exit(1); + } + println!( + "Trying {:?}, use `ping localhost` to see changes!", + lo_stats + ); + paths.push(lo_stats); } - println!("Trying {:?}, use `ping localhost` to see changes!", lo_stats); - paths.push(lo_stats); - } - println!("watching {:?}...", paths); + println!("watching {:?}...", paths); - let config = PollWatcherConfig { - compare_contents: true, - poll_interval: Duration::from_secs(2), - }; - let (tx, rx) = std::sync::mpsc::channel(); - let mut watcher = PollWatcher::with_config(tx, config)?; - for path in paths { - watcher.watch(&path, RecursiveMode::Recursive)?; - } + let config = PollWatcherConfig { + compare_contents: true, + poll_interval: Duration::from_secs(2), + }; + let (tx, rx) = std::sync::mpsc::channel(); + let mut watcher = PollWatcher::with_config(tx, config)?; + for path in paths { + watcher.watch(&path, RecursiveMode::Recursive)?; + } - for res in rx { - match res { - Ok(event) => println!("changed: {:?}", event), - Err(e) => println!("watch error: {:?}", e), + for res in rx { + match res { + Ok(event) => println!("changed: {:?}", event), + Err(e) => println!("watch error: {:?}", e), + } } - } - Ok(()) + Ok(()) } fn main() -> notify::Result<()> { - #[cfg(not(target_os = "windows"))] - { - not_windows_main() - } -} \ No newline at end of file + #[cfg(not(target_os = "windows"))] + { + not_windows_main() + } +}