Rust中如何对结构体集合实例依次执行方法遇错即停？

尝试对集合中的每个LogCommand结构体实例执行execute方法，要求遇到错误时立即停止执行后续实例。使用futures库的流式处理写法时遇到编译错误，希望不直接使用for循环，以更函数式的方式实现需求。

原代码 #

use std::pin::Pin;
use std::future::Future;

use anyhow::Error;
use futures::future::ok;
use futures::stream::{TryStream, TryStreamExt};

pub struct LogCommand {
    message: String,
}

impl LogCommand {
    fn new(message: String) -> LogCommand {
        LogCommand { message }
    }

    fn execute(&self) -> Pin<Box<dyn Future<Output = Result<bool, Error>>>> {
        println!("{}", self.message);
        Box::pin(ok(true))
    }
}

fn main() {
    let mut structs: Vec<LogCommand> = Vec::new();
    structs.push(LogCommand::new("Test1".to_string()));
    structs.push(LogCommand::new("Test2".to_string()));
    structs.push(LogCommand::new("Test3".to_string()));

    run_all_methods(structs);
}

async fn run_all_methods(logCommands: Vec<LogCommand>) -> Result<bool, Error> {
    futures::stream::iter(logCommands).try_for_each(|i| i.execute())
}

编译错误信息 #

the method `try_for_each` exists for struct `Iter<IntoIter<LogCommand>>`, but its trait bounds were not satisfied
the following trait bounds were not satisfied:
`futures::stream::Iter<std::vec::IntoIter<LogCommand>>: TryStream`
which is required by `futures::stream::Iter<std::vec::IntoIter<LogCommand>>: TryStreamExt`
`&futures::stream::Iter<std::vec::IntoIter<LogCommand>>: TryStream`
which is required by `&futures::stream::Iter<std::vec::IntoIter<LogCommand>>: TryStreamExt`
`&mut futures::stream::Iter<std::vec::IntoIter<LogCommand>>: TryStream`
which is required by `&mut futures::stream::Iter<std::vec::IntoIter<LogCommand>>: TryStreamExt`rustcClick for full compiler diagnostic
iter.rs(9, 1): doesn't satisfy `_: TryStreamExt`
iter.rs(9, 1): doesn't satisfy `_: TryStream`

错误原因 #

futures::stream::iter生成的是普通Stream，其元素类型为LogCommand，而非Result类型。而try_for_each是TryStreamExt trait下的方法，要求调用者必须实现TryStream trait（即流的元素为Result<T, E>），因此直接调用会触发编译错误。

修正方案 #

将普通流转换为TryStream，然后使用try_for_each顺序执行每个实例的execute方法，遇到错误立即终止。同时需要确保异步函数被正确执行（添加异步运行时）。

修正后的完整代码 #

use std::pin::Pin;
use std::future::Future;

use anyhow::Error;
use futures::future::ok;
use futures::stream::StreamExt;

pub struct LogCommand {
    message: String,
}

impl LogCommand {
    fn new(message: String) -> LogCommand {
        LogCommand { message }
    }

    fn execute(&self) -> Pin<Box<dyn Future<Output = Result<bool, Error>>>> {
        println!("{}", self.message);
        Box::pin(ok(true))
    }
}

// 使用tokio运行时执行异步逻辑
#[tokio::main]
async fn main() -> Result<(), Error> {
    let mut commands: Vec<LogCommand> = Vec::new();
    commands.push(LogCommand::new("Test1".to_string()));
    commands.push(LogCommand::new("Test2".to_string()));
    commands.push(LogCommand::new("Test3".to_string()));

    run_all_methods(commands).await?;
    Ok(())
}

async fn run_all_methods(log_commands: Vec<LogCommand>) -> Result<(), Error> {
    futures::stream::iter(log_commands)
        // 将每个元素包装为Ok，转换为TryStream
        .map(Ok)
        // 顺序执行每个命令，遇错即停
        .try_for_each(|cmd| async move {
            cmd.execute().await?;
            Ok(())
        })
}

关键改动说明 #

1. 添加异步运行时：使用#[tokio::main]宏让main函数支持异步执行，确保异步逻辑被正确调度（需在Cargo.toml中添加tokio = { version = "1.0", features = ["full"] }依赖）。
2. 转换为TryStream：通过map(Ok)将普通流的元素包装为Result<LogCommand, Error>，满足TryStream的 trait 要求。
3. 正确使用try_for_each：闭包内异步执行execute方法，通过?传播错误，一旦出错try_for_each会立即停止后续元素的处理并返回错误。

可选优化 #

如果execute方法不需要持有LogCommand的所有权，可以改为接收引用，同时在流中使用引用迭代，避免所有权转移：

// 保持execute方法不变（接收&self）
fn execute(&self) -> Pin<Box<dyn Future<Output = Result<bool, Error>>>> {
    println!("{}", self.message);
    Box::pin(ok(true))
}

// 修改run_all_methods为接收切片引用
async fn run_all_methods(log_commands: &[LogCommand]) -> Result<(), Error> {
    futures::stream::iter(log_commands)
        .map(Ok)
        .try_for_each(|cmd| async move {
            cmd.execute().await?;
            Ok(())
        })
}

// main中传递引用
run_all_methods(&commands).await?;

内容的提问来源于stack exchange，提问作者StoopMoss