diff options
author | root <github@bigly.dog> | 2024-03-23 03:09:07 -0700 |
---|---|---|
committer | root <github@bigly.dog> | 2024-03-23 03:11:55 -0700 |
commit | e9b64daba72f4233d93ef8ca21dcbfae1947161a (patch) | |
tree | 08a9f1f9b0f20beb8464c6bbe922c3742abbd2a8 | |
parent | 235d91a27bb04501e54e8a0f5b75a152d1271092 (diff) |
rm arc
-rw-r--r-- | src/main.rs | 11 |
1 files changed, 3 insertions, 8 deletions
diff --git a/src/main.rs b/src/main.rs index 9f83c56..f47cf80 100644 --- a/src/main.rs +++ b/src/main.rs @@ -32,7 +32,6 @@ use { path::PathBuf, pin::pin, process::{ExitCode, Termination}, - sync::Arc, thread::available_parallelism, }, subprocess::{stream_into, stream_subproc}, @@ -82,16 +81,12 @@ async fn run(threads: usize) -> Result<(), Die> { let (mode, args) = parse_args(); let input_stream = stream_in(&mode, &args).await; let opts = parse_opts(mode, args)?; - let options = Arc::new(opts); - let opts = options.clone(); + let trans_stream = input_stream - .map_ok(move |input| { - let opts = options.clone(); - async move { displace(&opts, input).await } - }) + .map_ok(|input| displace(&opts, input)) .try_buffer_unordered(threads); - let out_stream = stream_sink(&opts, trans_stream.boxed()); + consume(out_stream).await } |