inotify 0.7.1

Idiomatic wrapper for inotify
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44

extern crate futures;
extern crate inotify;
extern crate tempdir;


use std::{
    fs::File,
    io,
    thread,
    time::Duration,
};

use futures::Stream;
use inotify::{
    Inotify,
    WatchMask,
};
use tempdir::TempDir;


fn main() -> Result<(), io::Error> {
    let mut inotify = Inotify::init()
        .expect("Failed to initialize inotify");

    let dir = TempDir::new("inotify-rs-test")?;

    inotify.add_watch(dir.path(), WatchMask::CREATE | WatchMask::MODIFY)?;

    thread::spawn::<_, Result<(), io::Error>>(move || {
        loop {
            File::create(dir.path().join("file"))?;
            thread::sleep(Duration::from_millis(500));
        }
    });

    let mut buffer = [0; 32];
    let stream = inotify.event_stream(&mut buffer);

    for event in stream.wait() {
        print!("event: {:?}\n", event);
    }

    Ok(())
}