rty 0.2.2

A simple command line retry tool.
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

impl super::AsyncWriteUnpin for tokio::io::Stdout {}

impl super::AsyncWriteUnpin for tokio::io::Stderr {}

#[derive(new)]
pub struct TokioProcess;

impl super::Process for TokioProcess {
    fn stdout(&self) -> Box<dyn super::AsyncWriteUnpin> {
        Box::new(tokio::io::stdout())
    }

    fn stderr(&self) -> Box<dyn super::AsyncWriteUnpin> {
        Box::new(tokio::io::stderr())
    }
}

#[cfg(test)]
impl super::AsyncWriteUnpin for Vec<u8> {}

#[cfg(test)]
pub struct StubProcess {
    pub stdout: Vec<u8>,
    pub stderr: Vec<u8>,
}

#[cfg(test)]
impl super::Process for StubProcess {
    fn stdout(&self) -> Box<dyn super::AsyncWriteUnpin> {
        Box::new(self.stdout.clone())
    }

    fn stderr(&self) -> Box<dyn super::AsyncWriteUnpin> {
        Box::new(self.stderr.clone())
    }
}