如何指示异步函数返回值的生命周期与参数相同？

Question

我们可以将普通函数与非静态参数进行匹配，如下所示：

fn processor(data: &i32) -> &i32 {
    data
}

fn process<'b>(data: &'b i32, processor: impl 'static + for<'a> Fn(&'a i32) -> &'a i32) -> &'b i32 {
    processor(data)
}

fn main() {
    let data = 1;
    println!("data: {}", process(&data, processor));
}

由于异步函数返回匿名期货，我们不能指出匿名期货的生命周期与参数相同：

use std::future::Future;

async fn processor(data: &i32) -> &i32 {
    data
}

async fn process<'b, F>(data: &'b i32, processor: impl 'static + Fn(&i32) -> F) -> &'b i32
where
    F: 'b + Future<Output = &'b i32>,
{
    processor(data).await
}

async fn _main() {
    let data = 1;
    println!("data: {}", process(&data, processor).await);
}

编译器会抱怨：

fn processor(data: &i32) -> &i32 {
    data
}

fn process<'b>(data: &'b i32, processor: impl 'static + for<'a> Fn(&'a i32) -> &'a i32) -> &'b i32 {
    processor(data)
}

fn main() {
    let data = 1;
    println!("data: {}", process(&data, processor));
}

我怎样才能匹配它？

Answer 1

您需要声明：

1. 闭包接受与参数具有相同生命周期的引用。
2. 返回的未来返回一个与参数具有相同生命周期的引用。
3. 返回的 future 捕获与参数具有相同生命周期的引用。

async fn process<'b, F, Fut>(data: &'b i32, processor: F) -> &'b i32
where
    F: Fn(&'b i32) -> Fut,
    //     ^^ [1]
    F: 'static,
    Fut: Future<Output = &'b i32> + 'b,
    //                    ^^ [2]    ^^ [3]
{
    processor(data).await
}