cancel-safe-futures

更具有取消感知能力的替代futures适配器。

这个crate是什么？

这个crate解决了几个相关但不同的问题

1. 可取消安全的futures适配器

futures 库包含许多适配器，使得编写异步Rust代码更加愉快。然而，其中一些组合器使得在超时、select! 分支或类似情况下的取消难以实现。

对于更详细的解释，请参阅 SinkExt::reserve 的文档。

示例

尝试使用超时循环发送项目

use cancel_safe_futures::prelude::*;
use std::time::Duration;

let mut my_sink = /* ... */;

// This item is stored here and will be set to None once the loop exits successfully.
let mut item = Some("hello".to_owned());
let do_flush = false;

while item.is_some() {
    match tokio::time::timeout(Duration::from_secs(10), my_sink.reserve()).await {
        Ok(Ok(permit)) => {
            let item = item.take().unwrap();
            if !do_flush {
                // permit.feed() feeds the item into the sink without flushing
                // the sink afterwards. This is a synchronous method.
                permit.feed(item)?;
            } else {
                // Alternatively, permit.send() writes the item into the sink
                // synchronously, then returns a future which can be awaited to
                // flush the sink.
                permit.send(item)?.await?;
            }
        }
        Ok(Err(error)) => return Err(error),
        Err(timeout_error) => continue,
    }
}

2. 不执行取消的 then_try 适配器

futures 和 tokio 库附带了许多 try_ 适配器和宏，例如 tokio::try_join!。这些适配器具有以下特性：如果考虑的futures之一失败，所有其他futures都将被取消。

这并不总是期望的，并导致了正确性错误（例如，omicron PR 3707）。为了解决这个问题，这个crate提供了一组 then_try 适配器和宏，它们的行为类似于它们的 try_ 对应物，但如果有或多个futures出错，其他futures仍将运行到完成。

then_try 家族包括