rusht 1.1.0

Shell commands written in Rust
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 ::std::future::join;

use crate::common::LineWriter;
use crate::common::{LineReader, StdWriter, Task};
use crate::observe::chain::ChainWriter;
use crate::observe::chained;
use crate::observe::piped_args::PipedArgs;
use crate::ExitStatus;

pub async fn piped(
    args: PipedArgs,
    _reader: &mut impl LineReader,
    writer: &mut impl LineWriter,
) -> ExitStatus {
    assert!(!args.stderr);
    let (source, sink) = args.cmds.split_once_at(&args.separator);
    let source = source.into_task();
    let sink = sink.into_task();
    //source.execute_with_stdout();
    let (mut chain_write, _chain_read) =
        chained(args.pipe_buffer_size.try_into().unwrap_or(usize::MAX));
    let (source_res, sink_res) = join!(
        run_source(source, &mut chain_write, args.stderr),
        //TODO @mverleg: chain_read into this cmd:
        sink.execute_with_stdout_nomonitor(writer, &mut StdWriter::stderr()),
    )
    .await;
    ExitStatus::max(source_res, sink_res)
}

async fn run_source(task: Task, writer: &mut ChainWriter, is_stderr: bool) -> ExitStatus {
    if is_stderr {
        task.execute_with_stdout_nomonitor(&mut StdWriter::stdout(), writer)
            .await
    } else {
        task.execute_with_stdout_nomonitor(writer, &mut StdWriter::stderr())
            .await
    }
}