diff --git a/src/commands/autoview.rs b/src/commands/autoview.rs index b9b9d8941c..e715491e91 100644 --- a/src/commands/autoview.rs +++ b/src/commands/autoview.rs @@ -1,6 +1,7 @@ use crate::commands::{RawCommandArgs, WholeStreamCommand}; use crate::errors::ShellError; use crate::prelude::*; +use futures_async_stream::async_stream_block; pub struct Autoview; diff --git a/src/commands/plugin.rs b/src/commands/plugin.rs index ae9b2ec64a..4e30b68f45 100644 --- a/src/commands/plugin.rs +++ b/src/commands/plugin.rs @@ -3,6 +3,7 @@ use crate::errors::ShellError; use crate::parser::registry; use crate::prelude::*; use derive_new::new; +use futures_async_stream::async_stream_block; use log::trace; use serde::{self, Deserialize, Serialize}; use std::io::prelude::*; diff --git a/src/commands/save.rs b/src/commands/save.rs index 9c12fd2414..982e578a8a 100644 --- a/src/commands/save.rs +++ b/src/commands/save.rs @@ -2,6 +2,7 @@ use crate::commands::{UnevaluatedCallInfo, WholeStreamCommand}; use crate::data::Value; use crate::errors::ShellError; use crate::prelude::*; +use futures_async_stream::async_stream_block; use std::path::{Path, PathBuf}; pub struct Save; diff --git a/src/prelude.rs b/src/prelude.rs index b80e21f034..56cd21b33a 100644 --- a/src/prelude.rs +++ b/src/prelude.rs @@ -76,7 +76,6 @@ pub(crate) use async_stream::stream as async_stream; pub(crate) use bigdecimal::BigDecimal; pub(crate) use futures::stream::BoxStream; pub(crate) use futures::{FutureExt, Stream, StreamExt}; -pub(crate) use futures_async_stream::async_stream_block; pub(crate) use num_bigint::BigInt; pub(crate) use num_traits::cast::{FromPrimitive, ToPrimitive}; pub(crate) use num_traits::identities::Zero;