如何在 Rust 的重试中使用异步闭包-解网

问：

我必须重试一个异步函数 - 并且我正在使用它的重试 crate（版本“1.2.1”）。但第二个论点是结束。handle_message

use retry::{retry, delay::Fixed};

retry(Fixed::from_millis(10000).take(3), || async {
    let message = handle_message(my_message.clone()).await;

    match message {
        Ok(()) => info!("Message successfully registered"),
        Err(e) => {
            // For certain errors likely to resolve if we wait a bit, we schedule a retry
            if e.is_code(EC::MyErrorCode, true)
            {
                debug!("Handling message error- {:?}", e);
                return Err(format!("Dkg message w/ error: {:?}", e));
            }
        }
    }

    Ok(()) // Don't try any other errors
});

我收到以下错误：

the trait bound `OperationResult<_, _>: From<[async block@src/my_file.rs:xx:xx]>` is not satisfied
the trait `From<std::result::Result<T, E>>` is implemented for `OperationResult<T, E>`
required for `[async block@src/my_file.rs:xx:xx]` to implement `Into<OperationResult<_, _>>`

我也尝试从异步闭包返回，但我仍然收到同样的错误。OperationResult::Ok/ErrResult::Ok/Err

是否可以在重试块中使用异步函数？

异步 rust 作用域闭包 retry-logic

use std::time::Duration;
use tryhard::RetryPolicy;

tryhard::retry_fn(|| read_file("Cargo.toml"))
    .retries(10)
    .custom_backoff(|attempt, error: &std::io::Error| {
        if error.to_string().contains("foobar") {
            // returning this will cancel the loop and
            // return the most recent error
            RetryPolicy::Break
        } else {
            RetryPolicy::Delay(Duration::from_millis(50))
        }
    })
    .await?;

如果迁移对你来说太多了，请尝试取消异步调用，阻止当前线程。对于 tokio 来说，这是一个鼓舞人心的例子，它可能应该用 spawn_blocking 来推动 IO 向前发展：

let message = tokio::runtime::Handle::current().block_on(
  handle_message(my_message.clone())
);

上一个：在函数闭包中自包含 RNG 种子

下一个：Javasript 闭包 stange 行为

如何在 Rust 的重试中使用异步闭包

How to use an async closure in Rust's retry

评论