我有以下代码(请参阅playground):
use futures::{stream, Future, Stream}; // 0.1.25
use std::num::ParseIntError;
fn into_many(i: i32) -> impl Stream<Item = i32, Error = ParseIntError> {
stream::iter_ok(0..i)
}
fn convert_to_string(number: i32) -> Result<String, ParseIntError> {
Ok(number.to_string())
}
fn main() {
println!("start:");
let vec = into_many(10)
.map(|number| convert_to_string(number))
.collect()
.wait()
.unwrap();
println!("vec={:#?}", vec);
println!("finish:");
}
它输出以下(即Vec<Result<i32, ParseIntError>>
):
start:
vec=[
Ok(
"0"
),
Ok(
"1"
),
Ok(
"2"
), ...
有没有办法让它输出一个Vec<i32>
,如果发生任何错误,立即停止执行并从函数返回(例如,像this example)?
注意:我确实想使用use futures::Stream; // 0.1.25
,即使它对这个特定的例子没有意义。
以下代码(playground link)作为您问题中当前代码的修改,可获得您想要的结果:
use futures::{stream, Future, Stream}; // 0.1.25
use std::num::ParseIntError;
fn into_many(i: i32) -> impl Stream<Item = i32, Error = ParseIntError> {
stream::iter_ok(0..i)
}
fn convert_to_string(number: i32) -> Result<String, ParseIntError> {
Ok(number.to_string())
}
fn main() {
println!("start:");
let vec: Result<Vec<String>, ParseIntError> = into_many(10)
.map(|number| convert_to_string(number))
.collect()
.wait()
.unwrap()
.into_iter()
.collect();
println!("vec={:#?}", vec);
println!("finish:");
}
由于您当前的代码返回了Vec
,我们可以将其转换为迭代器并将其收集到您想要的类型中。需要输入注释,以便collect知道要将迭代器收集到哪种类型。
请注意,collect
特征上的Iterator
方法不应与collect
上的Stream
方法混淆。
最后,虽然这有效,但它可能并不完全符合您的要求,因为在使用collect转换向量之前,它仍然会等待将流中的所有结果收集到向量中。我没有期货的经验所以不确定这是多么可能(它可能是但可能需要一个不太整洁的函数式编程风格的解决方案)。
map
具有返回Result
的函数
不要这样做,那不是你应该使用map
。相反,使用and_then
:
let vec = into_many(10)
.and_then(|number| convert_to_string(number))
.collect()
.wait()
.unwrap();
在潜入期货之前,您应该使用更简单的Rust概念,如Option
,Result
和迭代器。转移了许多概念。
也可以看看: