mirror of
https://github.com/danbulant/nushell
synced 2026-05-21 21:39:15 +00:00
16 lines
412 B
Rust
16 lines
412 B
Rust
use crate::prelude::*;
|
|
use futures::stream::BoxStream;
|
|
|
|
pub type InputStream = BoxStream<'static, Value>;
|
|
pub type OutputStream = BoxStream<'static, ReturnValue>;
|
|
|
|
crate fn empty_stream() -> OutputStream {
|
|
VecDeque::new().boxed()
|
|
}
|
|
|
|
crate fn single_output(item: Value) -> OutputStream {
|
|
let value = ReturnValue::Value(item);
|
|
let mut vec = VecDeque::new();
|
|
vec.push_back(value);
|
|
vec.boxed()
|
|
}
|