forked from extern/nushell
36 lines
1018 B
Rust
36 lines
1018 B
Rust
|
use crate::errors::ShellError;
|
||
|
|
use crate::object::{Primitive, Value};
|
||
|
|
use crate::prelude::*;
|
||
|
|
use log::trace;
|
||
|
|
|
||
|
|
// TODO: "Amount remaining" wrapper
|
||
|
|
|
||
|
|
pub fn lines(args: CommandArgs) -> Result<OutputStream, ShellError> {
|
||
|
|
let input = args.input;
|
||
|
|
|
||
|
|
let stream = input
|
||
|
|
.map(move |v| match v {
|
||
|
|
Value::Primitive(Primitive::String(s)) => {
|
||
|
|
let splitter = "\n";
|
||
|
|
let split_result: Vec<_> = s.split(&splitter).filter(|s| s.trim() != "").collect();
|
||
|
|
|
||
|
|
trace!("split result = {:?}", split_result);
|
||
|
|
|
||
|
|
let mut result = VecDeque::new();
|
||
|
|
for s in split_result {
|
||
|
|
result.push_back(ReturnValue::Value(Value::Primitive(Primitive::String(
|
||
|
|
s.to_string(),
|
||
|
|
))));
|
||
|
|
}
|
||
|
|
result
|
||
|
|
}
|
||
|
|
_ => {
|
||
|
|
let result = VecDeque::new();
|
||
|
|
result
|
||
|
|
}
|
||
|
|
})
|
||
|
|
.flatten();
|
||
|
|
|
||
|
|
Ok(stream.boxed())
|
||
|
|
}
|