use async_std::fs;
use async_std::task;
use async_fsw::{Watcher, WatchMode};
#[async_std::test]
async fn observes_path() {
let mut w = Watcher::new();
w.set_path("/tmp", WatchMode::Recursive);
w.observe().await.unwrap();
task::spawn(async move {
fs::write("/tmp/foo.txt", b"Lorem ipsum").await.unwrap();
});
let mut event = None;
while let Ok(e) = w.incomming().recv().await {
event = Some(e);
break;
}
assert!(event.is_some());
}