clankerdiff-watch 0.1.3

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

use super::{
    test_result::TestResult,
    wait::{assert_pending, wait_for},
};
use clankerdiff_git::{GitError, RepositorySnapshot};
use std::sync::Arc;
use tokio::sync::watch;

pub async fn wait_for_snapshot(
    state: &mut watch::Receiver<Result<Arc<RepositorySnapshot>, Arc<GitError>>>,
) -> TestResult<Arc<RepositorySnapshot>> {
    wait_for("snapshot publication", state.changed()).await?;
    Ok(state.borrow_and_update().clone()?)
}

pub async fn assert_snapshot_unchanged(
    state: &mut watch::Receiver<Result<Arc<RepositorySnapshot>, Arc<GitError>>>,
) {
    state.borrow_and_update();
    assert_pending("snapshot must remain unchanged", state.changed()).await;
}