summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorroot <github@bigly.dog>2024-03-23 03:09:07 -0700
committerroot <github@bigly.dog>2024-03-23 03:11:55 -0700
commite9b64daba72f4233d93ef8ca21dcbfae1947161a (patch)
tree08a9f1f9b0f20beb8464c6bbe922c3742abbd2a8
parent235d91a27bb04501e54e8a0f5b75a152d1271092 (diff)
rm arc
-rw-r--r--src/main.rs11
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
}