futures-retry

[发布文档]

[主文档]

一个帮助您重试未来的工具 :) 严格来说，是 Future 和 Stream。

当您遇到错误时，这是一个相当常见的任务，无论是连接超时还是一些临时的操作系统错误。

在同步方式中执行任务时，实现尝试逻辑相当简单，但一到异步编程，您突然需要写一大堆样板代码，引入状态机等等。

这个库旨在使您的生活更加轻松，并让您编写更简洁、更优雅的代码，专注于业务逻辑而不是处理所有乱七八糟的事情。

我在看到 hyper 问题 后受到启发编写了这个库，并且我意识到这个问题比我以前认为的更普遍。

有关示例，请参阅 Git 仓库中的 examples/ 文件夹。

欢迎提出建议和批评！

// ...
use futures_retry::{RetryPolicy, StreamRetryExt};

// In this example we use a free function to handle errors, while in your project you have
// more options: for simple cases a simple closure will do, for complex cases you might go
// as far as implementing an `ErrorHandler` trait for a custom type with some complex logic.
fn handle_error(e: io::Error) -> RetryPolicy<io::Error> {
  match e.kind() {
    io::ErrorKind::Interrupted => RetryPolicy::Repeat,
    io::ErrorKind::PermissionDenied => RetryPolicy::ForwardError(e),
    _ => RetryPolicy::WaitRetry(Duration::from_millis(5)),
  }
}

async fn serve_connection(stream: TcpStream) {
  // ...
}

#[tokio::main]
async fn main() {
  let addr = //...
  # "127.0.0.1:12345";
  let mut listener = TcpListener::bind(addr).await.unwrap();
  let server = stream::try_unfold(listener, |listener| async move {
    Ok(Some((listener.accept().await?.0, listener)))
  })
  .retry(handle_error) // Magic happens here
  .and_then(|(stream, _attempt)| {
    tokio::spawn(serve_connection(stream));
    ok(())
  })
  .try_for_each(|_| ok(()))
  .map_err(|(e, _attempt)| eprintln!("Caught an error {}", e));
  # // This nasty hack is required to exit immediately when running the doc tests.
  # futures::pin_mut!(server);
  # let server = select(ok::<_, ()>(()), server).map(|_| ());
  server.await
}

许可证

许可协议为以下之一

• Apache 许可证 2.0 (LICENSE-APACHE 或 http://www.apache.org/licenses/LICENSE-2.0)
• MIT 许可证 (LICENSE-MIT 或 http://opensource.org/licenses/MIT)

任选其一。

贡献

除非您明确声明，否则您提交给工作的任何贡献，根据 Apache-2.0 许可证的定义，将根据上述许可证双重许可，不附加任何额外的条款或条件。

许可证：MIT/Apache-2.0