diff --git a/crates/nu-command/src/system/run_external.rs b/crates/nu-command/src/system/run_external.rs index 658cd69de2..9f7c30ce10 100644 --- a/crates/nu-command/src/system/run_external.rs +++ b/crates/nu-command/src/system/run_external.rs @@ -188,7 +188,7 @@ impl ExternalCommand { std::thread::spawn(move || { // If this external is not the last expression, then its output is piped to a channel - // and we create a ValueStream that can be consumed + // and we create a ListStream that can be consumed if redirect_stderr { let _ = child.stderr.take(); @@ -444,8 +444,8 @@ fn trim_enclosing_quotes(input: &str) -> String { } } -// Receiver used for the ValueStream -// It implements iterator so it can be used as a ValueStream +// Receiver used for the ListStream +// It implements iterator so it can be used as a ListStream struct ChannelReceiver { rx: mpsc::Receiver>, } diff --git a/crates/nu-protocol/src/ty.rs b/crates/nu-protocol/src/ty.rs index 568a09b6af..a0b166c795 100644 --- a/crates/nu-protocol/src/ty.rs +++ b/crates/nu-protocol/src/ty.rs @@ -19,7 +19,7 @@ pub enum Type { Nothing, Record(Vec<(String, Type)>), Table, - ValueStream, + ListStream, Unknown, Error, Binary, @@ -53,7 +53,7 @@ impl Display for Type { Type::Nothing => write!(f, "nothing"), Type::Number => write!(f, "number"), Type::String => write!(f, "string"), - Type::ValueStream => write!(f, "value stream"), + Type::ListStream => write!(f, "list stream"), Type::Unknown => write!(f, "unknown"), Type::Error => write!(f, "error"), Type::Binary => write!(f, "binary"), diff --git a/crates/nu-protocol/src/value/stream.rs b/crates/nu-protocol/src/value/stream.rs index f6c26c3547..a111120f38 100644 --- a/crates/nu-protocol/src/value/stream.rs +++ b/crates/nu-protocol/src/value/stream.rs @@ -195,7 +195,7 @@ impl ListStream { impl Debug for ListStream { fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result { - f.debug_struct("ValueStream").finish() + f.debug_struct("ListStream").finish() } }