Refactor message printing in rm (#12799)

# Description
Changes the iterator in `rm` to be an iterator over
`Result<Option<String>, ShellError>` (an optional message or error)
instead of an iterator over `Value`. Then, the iterator is consumed and
each message is printed. This allows the
`PipelineData::print_not_formatted` method to be removed.

crates/nu-command/src/filesystem/rm.rs

@@ -3,7 +3,7 @@ use super::util::{get_rest_for_glob_pattern, try_interaction};
 use nu_engine::{command_prelude::*, env::current_dir};
 use nu_glob::MatchOptions;
 use nu_path::expand_path_with;
-use nu_protocol::NuGlob;
+use nu_protocol::{report_error_new, NuGlob};
 #[cfg(unix)]
 use std::os::unix::prelude::FileTypeExt;
 use std::{
@@ -118,8 +118,6 @@ fn rm(
     let interactive = call.has_flag(engine_state, stack, "interactive")?;
     let interactive_once = call.has_flag(engine_state, stack, "interactive-once")? && !interactive;
 
-    let ctrlc = engine_state.ctrlc.clone();
-
     let mut paths = get_rest_for_glob_pattern(engine_state, stack, call, 0)?;
 
     if paths.is_empty() {
@@ -341,9 +339,7 @@ fn rm(
         }
     }
 
-    all_targets
-        .into_iter()
-        .map(move |(f, span)| {
+    let iter = all_targets.into_iter().map(move |(f, span)| {
         let is_empty = || match f.read_dir() {
             Ok(mut p) => p.next().is_none(),
             Err(_) => false,
@@ -373,8 +369,7 @@ fn rm(
                 );
 
                 let result = if let Err(e) = interaction {
-                        let e = Error::new(ErrorKind::Other, &*e.to_string());
-                        Err(e)
+                    Err(Error::new(ErrorKind::Other, &*e.to_string()))
                 } else if interactive && !confirmed {
                     Ok(())
                 } else if TRASH_SUPPORTED && (trash || (rm_always_trash && !permanent)) {
@@ -384,10 +379,7 @@ fn rm(
                     ))]
                     {
                         trash::delete(&f).map_err(|e: trash::Error| {
-                                Error::new(
-                                    ErrorKind::Other,
-                                    format!("{e:?}\nTry '--permanent' flag"),
-                                )
+                            Error::new(ErrorKind::Other, format!("{e:?}\nTry '--permanent' flag"))
                         })
                     }
 
@@ -425,48 +417,52 @@ fn rm(
 
                 if let Err(e) = result {
                     let msg = format!("Could not delete {:}: {e:}", f.to_string_lossy());
-                        Value::error(ShellError::RemoveNotPossible { msg, span }, span)
+                    Err(ShellError::RemoveNotPossible { msg, span })
                 } else if verbose {
                     let msg = if interactive && !confirmed {
                         "not deleted"
                     } else {
                         "deleted"
                     };
-                        let val = format!("{} {:}", msg, f.to_string_lossy());
-                        Value::string(val, span)
+                    Ok(Some(format!("{} {:}", msg, f.to_string_lossy())))
                 } else {
-                        Value::nothing(span)
+                    Ok(None)
                 }
             } else {
                 let error = format!("Cannot remove {:}. try --recursive", f.to_string_lossy());
-                    Value::error(
-                        ShellError::GenericError {
+                Err(ShellError::GenericError {
                     error,
                     msg: "cannot remove non-empty directory".into(),
                     span: Some(span),
                     help: None,
                     inner: vec![],
-                        },
-                        span,
-                    )
+                })
             }
         } else {
             let error = format!("no such file or directory: {:}", f.to_string_lossy());
-                Value::error(
-                    ShellError::GenericError {
+            Err(ShellError::GenericError {
                 error,
                 msg: "no such file or directory".into(),
                 span: Some(span),
                 help: None,
                 inner: vec![],
-                    },
-                    span,
-                )
-            }
             })
-        .filter(|x| !matches!(x.get_type(), Type::Nothing))
-        .into_pipeline_data(span, ctrlc)
-        .print_not_formatted(engine_state, false, true)?;
+        }
+    });
+
+    for result in iter {
+        if nu_utils::ctrl_c::was_pressed(&engine_state.ctrlc) {
+            return Err(ShellError::InterruptedByUser {
+                span: Some(call.head),
+            });
+        }
+
+        match result {
+            Ok(None) => {}
+            Ok(Some(msg)) => eprintln!("{msg}"),
+            Err(err) => report_error_new(engine_state, &err),
+        }
+    }
 
     Ok(PipelineData::empty())
 }

crates/nu-protocol/src/pipeline_data/mod.rs

@@ -877,32 +877,6 @@ impl PipelineData {
         Ok(0)
     }
 
-    /// Consume and print self data immediately.
-    ///
-    /// Unlike [`.print()`] does not call `table` to format data and just prints it
-    /// one element on a line
-    /// * `no_newline` controls if we need to attach newline character to output.
-    /// * `to_stderr` controls if data is output to stderr, when the value is false, the data is output to stdout.
-    pub fn print_not_formatted(
-        self,
-        engine_state: &EngineState,
-        no_newline: bool,
-        to_stderr: bool,
-    ) -> Result<i64, ShellError> {
-        if let PipelineData::ExternalStream {
-            stdout: stream,
-            stderr: stderr_stream,
-            exit_code,
-            ..
-        } = self
-        {
-            print_if_stream(stream, stderr_stream, to_stderr, exit_code)
-        } else {
-            let config = engine_state.get_config();
-            self.write_all_and_flush(engine_state, config, no_newline, to_stderr)
-        }
-    }
-
     fn write_all_and_flush(
         self,
         engine_state: &EngineState,