clankerdiff-watch 0.1.2

Native filesystem watching and coalesced Git snapshot publication
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

use super::wait::{assert_pending, wait_for};
use clankerdiff_watch::file_watcher::FileWatcher;
use std::path::{Path, PathBuf};
use tokio::sync::mpsc;

pub async fn assert_invalidated(watcher: &mut impl FileWatcher) {
    assert_eq!(wait_for("invalidation", watcher.recv()).await, Some(()));
}

pub async fn assert_no_invalidation(watcher: &mut impl FileWatcher) {
    assert_pending("watcher must not invalidate or close", watcher.recv()).await;
}

pub async fn assert_watcher_closed(watcher: &mut impl FileWatcher) {
    assert_eq!(wait_for("watcher closure", watcher.recv()).await, None);
}

pub async fn wait_for_path(batches: &mut mpsc::UnboundedReceiver<Vec<PathBuf>>, path: &Path) {
    wait_for(
        &format!("filter batch containing {}", path.display()),
        async {
            loop {
                let paths = batches.recv().await.expect("filter remains alive");
                let mut unique = paths.clone();
                unique.sort();
                unique.dedup();
                assert_eq!(
                    paths.len(),
                    unique.len(),
                    "filter batches contain no duplicate paths"
                );
                if paths.iter().any(|candidate| candidate == path) {
                    break;
                }
            }
        },
    )
    .await;
}