diff --git a/crates/nu-command/src/commands/filters/each/command.rs b/crates/nu-command/src/commands/filters/each/command.rs index 0361683038..c3782233b6 100644 --- a/crates/nu-command/src/commands/filters/each/command.rs +++ b/crates/nu-command/src/commands/filters/each/command.rs @@ -69,7 +69,7 @@ impl WholeStreamCommand for Each { } pub fn process_row( - captured_block: Arc>, + captured_block: Arc, context: Arc, input: Value, external_redirection: ExternalRedirection, @@ -121,7 +121,7 @@ fn each(args: CommandArgs) -> Result { let block: CapturedBlock = args.req(0)?; let numbered: bool = args.has_flag("numbered"); - let block = Arc::new(Box::new(block)); + let block = Arc::new(block); if numbered { Ok(args diff --git a/crates/nu-command/src/commands/filters/each/group.rs b/crates/nu-command/src/commands/filters/each/group.rs index ebf5a4b014..2d82b3f972 100644 --- a/crates/nu-command/src/commands/filters/each/group.rs +++ b/crates/nu-command/src/commands/filters/each/group.rs @@ -43,7 +43,7 @@ impl WholeStreamCommand for EachGroup { let group_size: Tagged = args.req(0)?; let block: CapturedBlock = args.req(1)?; - let block = Arc::new(Box::new(block)); + let block = Arc::new(block); let each_group_iterator = EachGroupIterator { block, @@ -58,7 +58,7 @@ impl WholeStreamCommand for EachGroup { } struct EachGroupIterator { - block: Arc>, + block: Arc, context: Arc, group_size: usize, input: InputStream, @@ -96,7 +96,7 @@ impl Iterator for EachGroupIterator { pub(crate) fn run_block_on_vec( input: Vec, - block: Arc>, + block: Arc, context: Arc, external_redirection: ExternalRedirection, ) -> OutputStream { diff --git a/crates/nu-command/src/commands/filters/each/window.rs b/crates/nu-command/src/commands/filters/each/window.rs index 2b7efbd513..e5d855719c 100644 --- a/crates/nu-command/src/commands/filters/each/window.rs +++ b/crates/nu-command/src/commands/filters/each/window.rs @@ -49,7 +49,7 @@ impl WholeStreamCommand for EachWindow { let block: CapturedBlock = args.req(1)?; let stride: Option> = args.get_flag("stride")?; - let block = Arc::new(Box::new(block)); + let block = Arc::new(block); let mut window: Vec<_> = args .input diff --git a/crates/nu-command/src/commands/filters/group_by.rs b/crates/nu-command/src/commands/filters/group_by.rs index cd9841b4e9..c764d7b093 100644 --- a/crates/nu-command/src/commands/filters/group_by.rs +++ b/crates/nu-command/src/commands/filters/group_by.rs @@ -137,7 +137,7 @@ pub fn group_by(args: CommandArgs) -> Result { value: UntaggedValue::Block(block_given), .. }) => { - let block = Arc::new(block_given); + let block = Arc::new(*block_given); let error_key = "error"; for value in &values {