process-sync 0.2.2

Synchronization primitives for multiprocess environments
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

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

pub fn sleep(ms: u64) {
    std::thread::sleep(Duration::from_millis(ms));
}

pub struct TestOutput {
    expected: String,
    file: File,
}

impl TestOutput {
    pub fn new(expected_lines: &[&str]) -> Self {
        let expected = expected_lines.join("\n") + "\n";
        let file = File::create("tmp.txt").unwrap();
        Self { expected, file }
    }

    pub fn write_line(&mut self, line: impl AsRef<str>) {
        let line = line.as_ref();
        println!("{}", line);
        let line = format!("{}\n", line);
        self.file.write_all(line.as_bytes()).unwrap();
        self.file.flush().unwrap();
    }

    pub fn check(&self) {
        let output = std::fs::read_to_string("tmp.txt").unwrap();
        assert_eq!(output, self.expected);
        eprintln!("output matches ({} bytes)", output.len());
    }
}

impl Drop for TestOutput {
    fn drop(&mut self) {
        self.check();
    }
}